This is an automated email from the ASF dual-hosted git repository.
jchan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 263f3283724 [FLINK-33896] Remove Correlate Json Plan & Json IT tests
add 21403e31f47 [FLINK-33583][table-planner] Support state ttl hint for
regular join
No new revisions were added by this update.
Summary of changes:
.../apache/calcite/sql2rel/SqlToRelConverter.java | 28 +-
...uttle.java => CapitalizeQueryHintsShuttle.java} | 20 +-
...=> ClearQueryHintsOnUnmatchedNodesShuttle.java} | 26 +-
...arQueryHintsWithInvalidPropagationShuttle.java} | 85 +++---
.../table/planner/hint/FlinkHintStrategies.java | 64 +++-
.../flink/table/planner/hint/FlinkHints.java | 44 ++-
.../flink/table/planner/hint/JoinStrategy.java | 29 +-
...tsRelShuttle.java => QueryHintsRelShuttle.java} | 4 +-
.../flink/table/planner/hint/StateTtlHint.java | 90 ++++++
.../planner/plan/nodes/exec/StateMetadata.java | 22 +-
.../plan/nodes/exec/stream/StreamExecJoin.java | 4 +-
...nHintsResolver.java => QueryHintsResolver.java} | 157 +++++++---
.../table/planner/calcite/FlinkPlannerImpl.scala | 55 ++--
.../nodes/physical/common/CommonPhysicalJoin.scala | 7 +-
.../nodes/physical/stream/StreamPhysicalJoin.scala | 11 +-
.../optimize/CommonSubGraphBasedOptimizer.scala | 4 +-
.../rules/logical/FlinkSubQueryRemoveRule.scala | 6 +-
.../physical/batch/BatchPhysicalJoinRuleBase.scala | 8 +-
.../physical/stream/StreamPhysicalJoinRule.scala | 3 +-
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 6 +-
.../planner/plan/utils/RelTreeWriterImpl.scala | 9 +-
...nHintsWithCapitalizeQueryHintsShuttleTest.java} | 34 +--
...JoinHintsWithInvalidPropagationShuttleTest.java | 2 +-
...JoinHintsWithInvalidPropagationShuttleTest.java | 2 +-
...intsWithInvalidPropagationShuttleTestBase.java} | 25 +-
...eTtlHintsWithInvalidPropagationShuttleTest.java | 122 ++++++++
.../plan/hints/stream/StateTtlHintTest.java | 207 +++++++++++++
.../plan/nodes/exec/serde/StateMetadataTest.java | 23 +-
.../plan/nodes/exec/stream/JoinRestoreTest.java | 3 +-
.../plan/nodes/exec/stream/JoinTestPrograms.java | 18 ++
.../optimize/ClearQueryBlockAliasResolverTest.java | 6 +-
...solverTest.java => QueryHintsResolverTest.java} | 16 +-
.../ConfigureOperatorLevelStateTtlJsonITCase.java | 94 +++---
...inHintsWithCapitalizeQueryHintsShuttleTest.xml} | 0
...teTtlHintsWithInvalidPropagationShuttleTest.xml | 111 +++++++
.../planner/plan/hints/stream/StateTtlHintTest.xml | 282 ++++++++++++++++++
...ResolverTest.xml => QueryHintsResolverTest.xml} | 0
.../plan/join-with-state-ttl-hint.json | 322 +++++++++++++++++++++
.../join-with-state-ttl-hint/savepoint/_metadata | Bin 0 -> 19044 bytes
39 files changed, 1669 insertions(+), 280 deletions(-)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/{CapitalizeJoinHintsShuttle.java
=> CapitalizeQueryHintsShuttle.java} (74%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/{ClearJoinHintsOnUnmatchedNodesShuttle.java
=> ClearQueryHintsOnUnmatchedNodesShuttle.java} (74%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/{ClearJoinHintsWithInvalidPropagationShuttle.java
=> ClearQueryHintsWithInvalidPropagationShuttle.java} (64%)
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/{JoinHintsRelShuttle.java
=> QueryHintsRelShuttle.java} (94%)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/hint/StateTtlHint.java
rename
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/{JoinHintsResolver.java
=> QueryHintsResolver.java} (66%)
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/hint/{ClearJoinHintsWithCapitalizeJoinHintsShuttleTest.java
=> ClearJoinHintsWithCapitalizeQueryHintsShuttleTest.java} (81%)
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/hint/{ClearJoinHintsWithInvalidPropagationShuttleTestBase.java
=> ClearQueryHintsWithInvalidPropagationShuttleTestBase.java} (83%)
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/hint/ClearStateTtlHintsWithInvalidPropagationShuttleTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/hints/stream/StateTtlHintTest.java
rename
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/{JoinHintResolverTest.java
=> QueryHintsResolverTest.java} (88%)
rename
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/hint/{ClearJoinHintsWithCapitalizeJoinHintsShuttleTest.xml
=> ClearJoinHintsWithCapitalizeQueryHintsShuttleTest.xml} (100%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/hint/ClearStateTtlHintsWithInvalidPropagationShuttleTest.xml
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/hints/stream/StateTtlHintTest.xml
rename
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/optimize/{JoinHintResolverTest.xml
=> QueryHintsResolverTest.xml} (100%)
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-with-state-ttl-hint/plan/join-with-state-ttl-hint.json
create mode 100644
flink-table/flink-table-planner/src/test/resources/restore-tests/stream-exec-join_1/join-with-state-ttl-hint/savepoint/_metadata
