This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch release-2.1
in repository https://gitbox.apache.org/repos/asf/flink.git
from b6aeb26c7e2 [FLINK-38815] Mask sensitive values in Pekko debug
configuration logs
new ac6cc0b8bf1 [FLINK-38209][table-planner] Use UniqueKeys instead of
Upsertkeys for inputSpec and state management for MultiJoin
new 0e0a9d90407 [FLINK-38379][table] Adjust `visitMultiJoin` in
`RelTimeIndicatorConverter` to use fields and not rows
new 74404f8e8bc [FLINK-38554][table] Fix rowCount cost for
FlinkLogicalMultiJoin
new ce30d0317bb [FLINK-38576][table] Align commonJoinKey in MultiJoin for
logical and physical rules
new a0976628c6c [FLINK-38230][table-planner] Add visitMultiJoin to
StreamNDUPlanVisitor
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../table/utils/NoCommonJoinKeyException.java | 20 +-
.../planner/calcite/RelTimeIndicatorConverter.java | 4 +-
.../nodes/exec/stream/StreamExecMultiJoin.java | 31 +-
.../plan/nodes/logical/FlinkLogicalMultiJoin.java | 2 +-
.../physical/stream/StreamPhysicalMultiJoin.java | 79 +-
.../StreamNonDeterministicUpdatePlanVisitor.java | 100 ++
.../plan/rules/logical/JoinToMultiJoinRule.java | 169 +--
.../stream/StreamPhysicalMultiJoinRule.java | 114 +-
.../table/planner/plan/utils/MultiJoinUtil.java | 155 ++
.../NonDeterministicUpdateAnalyzerTest.java | 436 +++---
.../exec/serde/ExecNodeMultiJoinJsonSerdeTest.java | 6 +-
.../nodes/exec/stream/MultiJoinSemanticTests.java | 15 +-
.../nodes/exec/stream/MultiJoinTestPrograms.java | 178 ++-
.../nodes/exec/testutils/SemanticTestBase.java | 10 +
.../planner/plan/stream/sql/MultiJoinTest.java | 1516 ++++++++++++++++++--
.../analyze/NonDeterministicUpdateAnalyzerTest.xml | 36 +
.../planner/plan/stream/sql/MultiJoinTest.xml | 1391 +++++++++++-------
...our-way-complex-updating-join-with-restore.json | 527 ++++---
.../savepoint/_metadata | Bin 35162 -> 36360 bytes
...r-way-join-no-common-join-key-with-restore.json | 431 +++---
.../savepoint/_metadata | Bin 41248 -> 34081 bytes
.../plan/three-way-inner-join-with-restore.json | 244 ++--
.../savepoint/_metadata | Bin 21326 -> 20195 bytes
...way-join-with-time-attributes-with-restore.json | 89 +-
.../savepoint/_metadata | Bin 24946 -> 25432 bytes
.../three-way-left-outer-join-with-restore.json | 231 +--
.../savepoint/_metadata | Bin 21759 -> 21005 bytes
.../AttributeBasedJoinKeyExtractor.java | 3 +-
28 files changed, 4014 insertions(+), 1773 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
