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
