You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by sn...@apache.org on 2025/11/18 09:05:24 UTC

(flink) branch master updated (1c2d953556a -> bdbc8b589ee)

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

snuyanzin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


    from 1c2d953556a [FLINK-36625] Add lineage helper class for connector integration
     add bdbc8b589ee [FLINK-38576][table] Align commonJoinKey in MultiJoin for logical and physical rules

No new revisions were added by this update.

Summary of changes:
 .../table/utils/NoCommonJoinKeyException.java      |   20 +-
 .../plan/rules/logical/JoinToMultiJoinRule.java    |  168 +-
 .../stream/StreamPhysicalMultiJoinRule.java        |  126 +-
 .../table/planner/plan/utils/MultiJoinUtil.java    |  155 ++
 .../planner/plan/stream/sql/MultiJoinTest.java     | 1349 ++++++++++--
 .../planner/plan/stream/sql/MultiJoinTest.xml      | 2256 +++++++++++++++++---
 .../AttributeBasedJoinKeyExtractor.java            |    3 +-
 7 files changed, 3255 insertions(+), 822 deletions(-)
 copy flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/pekko/exceptions/RpcInvalidStateException.java => flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/NoCommonJoinKeyException.java (68%)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/utils/MultiJoinUtil.java