This is an automated email from the ASF dual-hosted git repository.
xuyangzhong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from e6d7a33507e [FLINK-39178][table-planner] Support cascaded delta join
in planner (#27734)
add d05555f9c89 [FLINK-39175][table-planner] Allow calc that contains
non-deterministic func to consume duplicate changes
add f71c6a16c97 [hotfix][table-planner] Fix comments in DeltaJoinTest
No new revisions were added by this update.
Summary of changes:
.../physical/stream/DuplicateChangesInferRule.java | 13 +-----
.../table/planner/plan/utils/DeltaJoinUtil.java | 9 ++--
.../stream/DuplicateChangesInferRuleTest.xml | 20 ++++-----
.../planner/plan/stream/sql/DeltaJoinTest.xml | 51 ++++++++++++++++++++++
.../planner/plan/stream/sql/DeltaJoinTest.scala | 29 ++++++++++--
5 files changed, 93 insertions(+), 29 deletions(-)
