DTStack / DTStack/flinkStreamSQL
Kudu维表在做join的时候,过滤条件不起作用
Aberta
- Linguagem predominante
- Java
- Estrelas
- 2k
- Forks
- 913
- Métricas de merge de PRs
- Nenhum PR com merge em 30d
Descrição
` 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也方法也没有被调用
Guia de contribuição
Nenhum guia de contribuição indexado para este repositório
Avaliação
Esta issue ainda não foi avaliada.