DTStack / DTStack/flinkStreamSQL

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

Aberta
#318 2 comentários 0 reações 0 responsáveis Ver no GitHub
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条件没有起作用。通过源码断点调试,发现下面的循环不能进去:

![image](https://user-images.githubusercontent.com/6110570/81462336-61f15b80-91e4-11ea-8be7-01369fb8b3f0.png)

继续排查发现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.

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.