1.10版本中发现连续Join时抛出数组越界异常
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 3/5
- Tiempo estimado
- 1-2 días
- Aptitud para principiantes
- 45/100
- Tipo de issue
- Error
- Claridad
- Bastante claro
- Estado de actividad
- Estancado
- Área
- stream-processing
Línea de trabajo
Comienza en com.dtstack.flink.sql.side.ParserJoinField, específicamente en getAllField(JoinScope scope), alrededor de las líneas 124-127, y reproduce la consulta indicada con dos joins a la misma tabla de dimensiones. Compara field.getFieldNames() con field.getTotalFields() cuando el campo contiene un Row y, a continuación, verifica que la consulta ya no produzca un error de índice de array.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
我将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需要进行表转流，流转表的时候才会遇到。
- Lenguaje dominante
- Java
- Estrellas
- 2k
- Forks
- 913
- Métricas de merge de PR
- Sin PR fusionados en 30 d
Guía de contribución
No hay ninguna guía de contribución indexada para este repositorio
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de DTStack/flinkStreamSQL
-
Dificultad 5/5 Más de una semana Aptitud para principiantes 20/100
DTStack/flinkStreamSQL#467 · 1 comentario ·
-
这个如何引入使用flink-connector-hive啊 Abierto
Dificultad 4/5 3-5 días Aptitud para principiantes 25/100
DTStack/flinkStreamSQL#437 · 3 comentarios ·
-
Dificultad 3/5 1-2 días Aptitud para principiantes 38/100
DTStack/flinkStreamSQL#432 · 1 comentario ·
-
新版FlinkStreamSQL已经融合进FlinkX项目 Abierto
Dificultad 5/5 Más de una semana Aptitud para principiantes 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 Abierto
Dificultad 5/5 Más de una semana Aptitud para principiantes 15/100
DTStack/flinkStreamSQL#430 · 1 comentario ·
Todos los issues de DTStack/flinkStreamSQL
Issues similares
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 85/100
-
Two open-case totals on one screen: the Programs tile says 15,858 and the nav badge says 15,868 Abiertobug frontend maui-pilot
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100
objectionary/eo-graphs#74 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 65/100