Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
1.16.1
-
None
Description
I have a case in test.sql that records in table_1 left join fail will be discard by group window.
I check the interval join operator implements. If one record in left table join right table fail, the record will not be emitted realtime but emitted waiting for additional half join bound time. In the test.sql, table_1 left join table_2 in 5 minute bound, and the output will delay 2.5 minute this will cause window discard the records.
testing
input:
{"n":"n1","ts":"2023-02-24 14:00:00"} {"n":"n2","ts":"2023-02-24 14:00:00"} {"n":"n1","ts":"2023-02-24 14:06:01"}
{"n":"n1","ts":"2023-02-24 14:00:00","v":111} {"n":"n1","ts":"2023-02-24 14:06:01","v":111}
output:
expect:
real:
I remove this logic in https://github.com/apache/flink/pull/22014 Please help to review this PR.
Attachments
Attachments
Issue Links
- duplicates
-
FLINK-18996 Avoid disorder for time interval join
- Resolved
- links to