[jira] [Created] (FLINK-18996) Avoid disorder for time interval join

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-18996) Avoid disorder for time interval join

Shang Yuanchun (Jira)
Benchao Li created FLINK-18996:
----------------------------------

             Summary: Avoid disorder for time interval join
                 Key: FLINK-18996
                 URL: https://issues.apache.org/jira/browse/FLINK-18996
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / API, Table SQL / Runtime
            Reporter: Benchao Li


Currently, the time interval join will produce data with rowtime later than watermark. If we use the rowtime again in downstream, e.t. window aggregation, we'll lose some data.

 

reported from user-zh: [http://apache-flink.147419.n8.nabble.com/Re-flink-interval-join-tc4458.html#none]



--
This message was sent by Atlassian Jira
(v8.3.4#803005)