This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from f3bd4a4962f [FLINK-38347][Checkpoint] Tolerate RPC loss for cleanup in
file-merging manager (#26977)
add 58c5066f7a6 [FLINK-37936][table-planner] Support STATE TTL hints for
MultiJoin
No new revisions were added by this update.
Summary of changes:
.../org/apache/calcite/rel/rules/MultiJoin.java | 322 +++++++++++++++++++++
.../flink/table/planner/hint/StateTtlHint.java | 34 ++-
.../plan/nodes/logical/FlinkLogicalMultiJoin.java | 30 +-
.../physical/stream/StreamPhysicalMultiJoin.java | 8 +-
.../plan/rules/logical/JoinToMultiJoinRule.java | 83 +++++-
.../logical/ProjectMultiJoinTransposeRule.java | 1 +
.../planner/plan/rules/FlinkStreamRuleSets.scala | 7 +-
.../nodes/exec/stream/MultiJoinRestoreTest.java | 3 +-
.../nodes/exec/stream/MultiJoinTestPrograms.java | 57 ++++
.../planner/plan/stream/sql/MultiJoinTest.java | 18 ++
.../planner/plan/stream/sql/MultiJoinTest.xml | 54 ++++
...ay-inner-join-with-ttl-hints-with-restore.json} | 0
.../savepoint/_metadata | Bin 21331 -> 21336 bytes
13 files changed, 601 insertions(+), 16 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rel/rules/MultiJoin.java
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/{three-way-inner-join-with-restore/plan/three-way-inner-join-with-restore.json
=>
three-way-inner-join-with-ttl-hints-with-restore/plan/three-way-inner-join-with-ttl-hints-with-restore.json}
(100%)
copy
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-multi-join_1/{three-way-inner-join-with-restore
=> three-way-inner-join-with-ttl-hints-with-restore}/savepoint/_metadata (83%)
