This is an automated email from the ASF dual-hosted git repository.

gustavodemorais pushed a change to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 3d20ecb1dfb [FLINK-40858][table] Non-equi joins fix: join key-only 
deletes with the stored record
     add 768a0379c63 [FLINK-40368][table] Deduplicate output should only be 
insert-only when ordered by time attribute (#29372)

No new revisions were added by this update.

Summary of changes:
 .../metadata/FlinkRelMdModifiedMonotonicity.scala  | 15 +----
 .../FlinkChangelogModeInferenceProgram.scala       |  4 +-
 .../flink/table/planner/plan/utils/RankUtil.scala  | 16 +++---
 .../planner/plan/stream/sql/DeduplicateTest.xml    | 66 ++++++++++++++++++++++
 .../planner/plan/stream/sql/DeduplicateTest.scala  | 33 +++++++++++
 .../runtime/stream/sql/DeduplicateITCase.scala     | 57 +++++++++++++++++++
 6 files changed, 169 insertions(+), 22 deletions(-)

Reply via email to