Lyn Zhang created FLINK-31212:
---------------------------------
Summary: Data lost if window group after interval left join
Key: FLINK-31212
URL: https://issues.apache.org/jira/browse/FLINK-31212
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Reporter: Lyn Zhang
Attachments: image-2023-02-24-17-58-44-461.png,
image-2023-02-24-17-58-57-238.png, image-2023-02-24-17-59-25-179.png,
image-2023-02-24-18-00-52-891.png, test.sql
I have a case in [^test.sql] that some 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 emit realtime but emit waiting for 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.
h2. testing
h4. input:
!image-2023-02-24-17-58-44-461.png!
!image-2023-02-24-17-58-57-238.png!
h4. output:
expect:
!image-2023-02-24-18-00-52-891.png!
real:
!image-2023-02-24-17-59-25-179.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
