[jira] [Created] (FLINK-19881) Optimize temporal join with upsert-Source(upsert-kafka)

[Shang Yuanchun (Jira)]

Leonard Xu created FLINK-19881:
----------------------------------

             Summary: Optimize temporal join with upsert-Source(upsert-kafka)
                 Key: FLINK-19881
                 URL: https://issues.apache.org/jira/browse/FLINK-19881
             Project: Flink
          Issue Type: Sub-task
            Reporter: Leonard Xu


Currently upsert-kafka will do normalize in a physical node named `ChangelogNormalize`, the normalization will do a deduplicate using state and produce `UPDATE_AFTER`, `DELETE` changelog. We do same thing In the state of temporal join operator,  we can merge them to one as an optimization  if the query contains temporal join an upsert-kafka.

 



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