flinkStreamSQL icon indicating copy to clipboard operation
flinkStreamSQL copied to clipboard

Kudu维表在做join的时候,过滤条件不起作用

Open wsy858 opened this issue 5 years ago • 2 comments

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条件没有起作用。通过源码断点调试,发现下面的循环不能进去:

image

继续排查发现KuduAsyncSideInfo类的buildEqualInfo方法是空的实现, dealOneEqualCon也方法也没有被调用

wsy858 avatar May 09 '20 03:05 wsy858

和kudu维表join的时候,使用event_time做时间窗口聚合,貌似只能触发一次,后面不管时间多久都不能写到sink,这个是什么问题?

wsy858 avatar May 12 '20 02:05 wsy858

同碰到这个问题,解决了吗

aptx4869hrj avatar Aug 14 '20 08:08 aptx4869hrj