This is an automated email from the ASF dual-hosted git repository.
lincoln pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from f33abffe1da [FLINK-34975][state/forst] Support multiget for forstdb
(#25363)
new 1543c724556 [FLINK-34702][table-planner] Avoid using
StreamPhysicalDeduplicate and instead decide to perform exec node
transformations in StreamPhysicalRank
new 00625b0019e [FLINK-34702][table-planner] Remove
StreamPhysicalDeduplicate from FlinkChangelogModeInferenceProgram and
StreamNonDeterministicUpdatePlanVisitor
new 9df9dce57e6 [FLINK-34702][table-planner] Remove
StreamPhysicalDeduplicate from FlinkRelMdColumnUniqueness
new e81b1089d17 [FLINK-34702][table-planner] Remove
StreamPhysicalDeduplicate from FlinkRelMdUniqueKeys
new 026f233ef03 [FLINK-34702][table-planner] Remove
StreamPhysicalDeduplicate from FlinkRelMdModifiedMonotonicity
new a134711aeca [FLINK-34702][table-planner] Remove
StreamPhysicalDeduplicate from FlinkRelMdUpsertKeys
new 2f8b2d81a97 [FLINK-34702][table-planner] Remove physical node
StreamPhysicalDeduplicate
The 7 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:
.../StreamNonDeterministicUpdatePlanVisitor.java | 19 ----
.../TemporalJoinRewriteWithUniqueKeyRule.java | 6 +-
.../plan/metadata/FlinkRelMdColumnUniqueness.scala | 39 ++++---
.../metadata/FlinkRelMdModifiedMonotonicity.scala | 111 ++++++++++---------
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 23 +---
.../plan/metadata/FlinkRelMdUpsertKeys.scala | 23 ++--
.../stream/StreamPhysicalDeduplicate.scala | 86 ---------------
.../nodes/physical/stream/StreamPhysicalRank.scala | 71 +++++++++----
.../FlinkChangelogModeInferenceProgram.scala | 14 +--
.../planner/plan/rules/FlinkStreamRuleSets.scala | 1 -
.../stream/StreamPhysicalDeduplicateRule.scala | 99 -----------------
.../physical/stream/StreamPhysicalRankRule.scala | 19 ++--
.../flink/table/planner/plan/utils/RankUtil.scala | 60 ++++++++---
.../nodes/exec/operator/StreamOperatorNameTest.xml | 4 +-
.../physical/stream/ChangelogModeInferenceTest.xml | 2 +-
.../planner/plan/stream/sql/DeduplicateTest.xml | 33 +++++-
.../plan/stream/sql/NonDeterministicDagTest.xml | 105 ++++++++++++++++++
.../table/planner/plan/stream/sql/RankTest.xml | 6 +-
.../plan/stream/sql/agg/GroupWindowTest.xml | 2 +-
.../plan/stream/sql/agg/WindowAggregateTest.xml | 8 +-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 43 +++++---
.../planner/plan/stream/sql/DeduplicateTest.scala | 26 +++++
.../plan/stream/sql/NonDeterministicDagTest.scala | 118 ++++++++++++---------
.../table/planner/plan/stream/sql/RankTest.scala | 17 +--
.../plan/stream/sql/agg/WindowAggregateTest.scala | 2 +-
25 files changed, 482 insertions(+), 455 deletions(-)
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamPhysicalDeduplicate.scala
delete mode 100644
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamPhysicalDeduplicateRule.scala
