1.10版本中发现连续Join时抛出数组越界异常
Chưa có ai nhận issue này.
Đánh giá
- Độ khó
- 3/5
- Thời gian dự kiến
- 1-2 ngày
- Mức phù hợp với người mới
- 45/100
- Loại issue
- Lỗi
- Độ rõ ràng
- Khá rõ ràng
- Mức độ hoạt động
- Đình trệ
- Lĩnh vực
- stream-processing
Hướng nghiên cứu
Bắt đầu trong com.dtstack.flink.sql.side.ParserJoinField, cụ thể là getAllField(JoinScope scope) quanh các dòng 124-127, và tái hiện truy vấn được báo cáo với hai phép join tới cùng một bảng dimension. So sánh field.getFieldNames() với field.getTotalFields() khi field chứa một Row, sau đó xác minh rằng truy vấn không còn phát sinh lỗi chỉ mục mảng.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Mô tả
我将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需要进行表转流，流转表的时候才会遇到。
- Ngôn ngữ chính
- Java
- Star
- 2k
- Fork
- 913
- Chỉ số merge pull request
- Không có pull request nào được merge trong 30 ngày
Hướng dẫn đóng góp
Chưa lập chỉ mục được hướng dẫn đóng góp cho kho mã nguồn này
Bắt đầu từ đâu
- Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
- Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
- Fork repository và làm thay đổi trên một nhánh.
- Mở pull request có tham chiếu số hiệu của issue.
Issue khác của DTStack/flinkStreamSQL
-
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 20/100
DTStack/flinkStreamSQL#467 · 1 bình luận ·
-
这个如何引入使用flink-connector-hive啊 Đang mở
Độ khó 4/5 3-5 ngày Mức phù hợp với người mới 25/100
DTStack/flinkStreamSQL#437 · 3 bình luận ·
-
Độ khó 3/5 1-2 ngày Mức phù hợp với người mới 38/100
DTStack/flinkStreamSQL#432 · 1 bình luận ·
-
新版FlinkStreamSQL已经融合进FlinkX项目 Đang mở
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 15/100
DTStack/flinkStreamSQL#431 ·
-
有无对sql 语法校验的方法 Đang mở
Độ khó 5/5 Hơn một tuần Mức phù hợp với người mới 15/100
DTStack/flinkStreamSQL#430 · 1 bình luận ·
Tất cả issue của DTStack/flinkStreamSQL
Issue tương tự
-
bug untriaged
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 84/100
opensearch-project/ml-commons#5094 ·
-
bug
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 85/100
-
emitter:client:csharp feature
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
-
affects/8.10 affects/8.9 component/clients kind/bug likelihood/mid severity/mid
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 78/100
-
Two open-case totals on one screen: the Programs tile says 15,858 and the nav badge says 15,868 Đang mởbug frontend maui-pilot
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100