Kudu维表在做join的时候,过滤条件不起作用
Ninguém assumiu esta issue ainda.
Avaliação
- Dificuldade
- 4/5
- Tempo estimado
- 3-5 dias
- Facilidade para iniciantes
- 30/100
Direção de pesquisa
O relatório aponta para KuduAsyncSideInfo.buildEqualInfo e diz que dealOneEqualCon nunca é chamado; comece localizando esses métodos e reproduzindo o SQL mostrado na tabela lateral do Kudu. Rastreie a configuração do join e verifique se a condição ON é aplicada, em vez de produzir uma contagem de produto cartesiano; em seguida, adicione ou atualize a cobertura para o comportamento corrigido.
Escrita pelo modelo de indexação a partir do texto da issue.
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也方法也没有被调用
- Linguagem predominante
- Java
- Estrelas
- 2k
- Forks
- 911
- Métricas de merge de PRs
- Nenhum PR com merge em 30d
Preparar o ambiente
Este projeto não oferece contêiner de desenvolvimento, Dockerfile nem guia de contribuição, então a configuração fica por sua conta: comece pelo README e veja nosso guia da primeira contribuição para os passos gerais.
Primeiros passos
- Leia a issue inteira e depois o guia de contribuição do projeto.
- Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
- Faça um fork do repositório e trabalhe em uma branch.
- Abra um pull request que referencie o número da issue.
Mais de DTStack/flinkStreamSQL
-
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 20/100
DTStack/flinkStreamSQL#467 · 1 comentário ·
-
Dificuldade 4/5 3-5 dias Facilidade para iniciantes 25/100
DTStack/flinkStreamSQL#437 · 3 comentários ·
-
Dificuldade 3/5 1-2 dias Facilidade para iniciantes 38/100
DTStack/flinkStreamSQL#432 · 1 comentário ·
-
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法Aberta
Dificuldade 5/5 Mais de uma semana Facilidade para iniciantes 15/100
DTStack/flinkStreamSQL#430 · 1 comentário ·
Todas as issues de DTStack/flinkStreamSQL
Issues semelhantes
-
Update license yearAberta0 - Backlog 1 - Ready documentation good first issue help wanted
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 78/100
-
cbor
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 84/100
FasterXML/jackson-dataformats-binary#844 ·
Mantenedores costumam responder em até 1 dia
-
Issue: Bug
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 82/100
OpenAPITools/openapi-generator#25107 ·
Mantenedores costumam responder em até 1 dia
-
improvement
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 78/100
apache/iceberg#18351 · 1 comentário ·
Mantenedores costumam responder em até 1 dia
-
bug good first issue
Dificuldade 2/5 1-3 horas Facilidade para iniciantes 90/100
repowise-dev/repowise#2945 · 1 comentário ·
Mantenedores costumam responder em até 1 dia