DTStack / DTStack/flinkStreamSQL

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

未关闭
#318 2 条评论 0 个 reaction 已指派 0 人 在 GitHub 查看
主要语言
Java
星标
2k
派生
913
PR 合并指标
30 天内没有已合并 PR

描述

` 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](https://user-images.githubusercontent.com/6110570/81462336-61f15b80-91e4-11ea-8be7-01369fb8b3f0.png)

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

贡献指南

这个仓库没有索引到贡献指南

评估

这个 Issue 还没有评估数据。

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。