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 04f3047d614 [FLINK-38396][tests] Make
`DefaultKubernetesArtifactUploaderTest` more stable
add ecd284da336 [FLINK-38401][table] Add getUpsertKeys support for
StreamPhysicalMultiJoin
No new revisions were added by this update.
Summary of changes:
.../physical/stream/StreamPhysicalMultiJoin.java | 4 +
.../stream/StreamPhysicalMultiJoinRule.java | 12 +
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 49 +-
.../plan/metadata/FlinkRelMdUpsertKeys.scala | 113 +++-
.../nodes/exec/stream/MultiJoinRestoreTest.java | 6 +-
.../nodes/exec/stream/MultiJoinTestPrograms.java | 247 +++++++++
.../analyze/NonDeterministicUpdateAnalyzerTest.xml | 4 +-
.../planner/plan/stream/sql/MultiJoinTest.xml | 50 +-
...complex-preserves-upsert-key-with-restore.json} | 616 +++++++++++----------
.../savepoint/_metadata | Bin 0 -> 24057 bytes
...ree-way-upsert-preserves-key-with-restore.json} | 245 +++++---
.../savepoint/_metadata | Bin 0 -> 20839 bytes
...ft-join-preserves-upsert-key-with-restore.json} | 248 ++++-----
.../savepoint/_metadata | Bin 0 -> 12484 bytes
14 files changed, 999 insertions(+), 595 deletions(-)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/{four-way-join-no-common-join-key-with-restore/plan/four-way-join-no-common-join-key-with-restore.json
=>
four-way-complex-preserves-upsert-key-with-restore/plan/four-way-complex-preserves-upsert-key-with-restore.json}
(56%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/four-way-complex-preserves-upsert-key-with-restore/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/{three-way-left-outer-join-with-restore/plan/three-way-left-outer-join-with-restore.json
=>
three-way-upsert-preserves-key-with-restore/plan/three-way-upsert-preserves-key-with-restore.json}
(53%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/three-way-upsert-preserves-key-with-restore/savepoint/_metadata
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/{three-way-inner-join-with-ttl-hints-with-restore/plan/three-way-inner-join-with-ttl-hints-with-restore.json
=>
two-way-left-join-preserves-upsert-key-with-restore/plan/two-way-left-join-preserves-upsert-key-with-restore.json}
(50%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/two-way-left-join-preserves-upsert-key-with-restore/savepoint/_metadata
