evan.wang
Results
1
issues of
evan.wang
` insert into dim_kafka_sink SELECT p.no, p.code, count(c.phone) tag_test_1 from bdl_kafka_source s inner join bdl_kudu_side c on c.user_id = s.user_id ` 使用1.8版本，在测试的时候，发现统计的结果是s表和c做笛卡尔积的数量，怀疑join中的on条件没有起作用。通过源码断点调试，发现下面的循环不能进去：  继续排查发现KuduAsyncSideInfo类的buildEqualInfo方法是空的实现， dealOneEqualCon也方法也没有被调用