Hacktoberfest 2026: as issues que os mantenedores marcaram para outubro, abertas e boas para iniciantes. Ver issues do Hacktoberfest

1.10版本中发现连续Join时抛出数组越界异常

Aberta
#304 3 comentários 0 reações 0 responsáveis Ver no GitHub

Ninguém assumiu esta issue ainda.

Avaliação

Dificuldade
3/5
Tempo estimado
1-2 dias
Facilidade para iniciantes
45/100
Tipo de issue
Bug
Clareza
Razoavelmente clara
Status de atividade
Estagnada
Stack de tecnologia
java, sql
Domínio
stream-processing

Direção de pesquisa

Comece em com.dtstack.flink.sql.side.ParserJoinField, especificamente em getAllField(JoinScope scope), por volta das linhas 124-127, e reproduza a consulta relatada com dois joins na mesma tabela de dimensão. Compare field.getFieldNames() com field.getTotalFields() quando o campo contiver um Row e, em seguida, verifique se a consulta não gera mais um erro de índice de array.

Escrita pelo modelo de indexação a partir do texto da issue.

Descrição

我将flinkStreamSql从1.8.1升级到1.10，原来可以运行的Join语句出错了。
tableA是源表， tableB 是维表，执行下面的语句
CREATE VIEW v_a_join_b AS
SELECT A.col_a1,A.col_a2,A.col_a3,B1.col_b as col_b1,B2.col_b as col_b2
FROM tableA AS A
LEFT JOIN tableB AS B1 ON A.col_a1 = B1.col_b
LEFT JOIN tableB AS B2 ON A.col_a2 = B2.col_b;
在com.dtstack.flink.sql.side.ParserJoinField类的
private static List getAllField(JoinScope scope) 方法中
会出现124行，String[] fieldNames = field.getFieldNames(); 只有两个字段f1,f2,其中f1是true，f2是Row其实包含了很多字段。 但是在126行，field.getTotalFields()会是实际包含的字段数，这样在127行， String fieldName = fieldNames[i]; 就会抛出数组越界的异常。 这个问题只在 多次Join需要进行表转流，流转表的时候才会遇到。
UI5M81IRAH)Y3YB NRF6726

Linguagem predominante
Java
Estrelas
2k
Forks
913
Nenhum PR com merge em 30d

Guia de contribuição

Nenhum guia de contribuição indexado para este repositório

Primeiros passos

  1. Leia a issue inteira e depois o guia de contribuição do projeto.
  2. Comente na issue dizendo que vai assumir — evita que duas pessoas façam o mesmo trabalho.
  3. Faça um fork do repositório e trabalhe em uma branch.
  4. Abra um pull request que referencie o número da issue.

Mais de DTStack/flinkStreamSQL

Todas as issues de DTStack/flinkStreamSQL

Issues semelhantes

Mais issues de Java

Receba novas issues na sua caixa de entrada

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