[jira] [Created] (FLINK-19830) Properly implements processing-time temporal table join

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

[jira] [Created] (FLINK-19830) Properly implements processing-time temporal table join

Shang Yuanchun (Jira)
Leonard Xu created FLINK-19830:
----------------------------------

             Summary: Properly implements processing-time temporal table join
                 Key: FLINK-19830
                 URL: https://issues.apache.org/jira/browse/FLINK-19830
             Project: Flink
          Issue Type: Sub-task
            Reporter: Leonard Xu


The exsiting TemporalProcessTimeJoinOperator has already supported temporal table join.
However, the semantic of this implementation is problematic, because the join processing for left stream doesn't wait for the complete snapshot of temporal table, this may mislead users in production environment.

Under the processing time temporal join semantics, to get the complete snapshot of temporal table may need introduce new mechanism in FLINK SQL in the future.



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