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)
