[flink] branch release-1.16 updated (e7f7e6b8c17 -> dbb6654c9d2)

[go...@apache.org]

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

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


    from e7f7e6b8c17 [FLINK-30539][tests] Removes timeout from YARNSessionCapacitySchedulerITCase
     add dbb6654c9d2 [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

No new revisions were added by this update.

Summary of changes:
 .../logical/EventTimeTemporalJoinRewriteRule.java  | 474 +++++++++++++++++++++
 .../plan/rules/logical/FlinkFilterJoinRule.java    |   2 +
 .../planner/plan/utils/TemporalTableJoinUtil.java  |  69 +++
 .../logical/FlinkLogicalTableSourceScan.scala      |  30 +-
 .../stream/StreamPhysicalTemporalJoin.scala        |   4 +-
 .../plan/optimize/program/FlinkStreamProgram.scala |  19 +-
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   2 +-
 .../TemporalJoinRewriteWithUniqueKeyRule.scala     |   7 +-
 .../stream/StreamPhysicalTableSourceScanRule.scala |   4 +-
 .../planner/plan/utils/TemporalJoinUtil.scala      |   7 +-
 ...AssignerChangelogNormalizeTransposeRuleTest.xml |   8 +-
 .../planner/plan/stream/sql/TableScanTest.xml      |   8 +-
 .../plan/stream/sql/join/TemporalJoinTest.xml      |  38 ++
 ...signerChangelogNormalizeTransposeRuleTest.scala |   2 +
 .../plan/stream/sql/join/TemporalJoinTest.scala    |  64 ++-
 .../runtime/stream/sql/TemporalJoinITCase.scala    |   5 +-
 .../temporal/TemporalRowTimeJoinOperatorTest.java  |  77 ++++
 17 files changed, 787 insertions(+), 33 deletions(-)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/EventTimeTemporalJoinRewriteRule.java
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/TemporalTableJoinUtil.java