This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 71ed78d [FLINK-25268][yarn] Support task manager node-label in Yarn
deployment
add d3b6a69 [FLINK-25123][table-planner] Remove redundant info for the
ExecNode's description
No new revisions were added by this update.
Summary of changes:
.../table/planner/delegation/BatchPlanner.scala | 4 +-
.../table/planner/delegation/StreamPlanner.scala | 4 +-
.../table/planner/plan/nodes/FlinkRelNode.scala | 41 ++++-
.../planner/plan/nodes/common/CommonCalc.scala | 24 ++-
.../batch/BatchPhysicalCorrelateBase.scala | 5 +-
.../nodes/physical/common/CommonPhysicalJoin.scala | 12 +-
.../physical/common/CommonPhysicalLookupJoin.scala | 43 ++---
.../stream/StreamPhysicalCorrelateBase.scala | 5 +-
.../stream/StreamPhysicalIntervalJoin.scala | 9 +-
.../physical/stream/StreamPhysicalMatch.scala | 6 +-
.../stream/StreamPhysicalWatermarkAssigner.scala | 6 +-
.../physical/stream/StreamPhysicalWindowJoin.scala | 9 +-
.../table/planner/plan/utils/FlinkRelOptUtil.scala | 2 +-
.../table/planner/plan/utils/FlinkRexUtil.scala | 83 +++++++--
.../table/planner/plan/utils/RelExplainUtil.scala | 60 +++++--
.../table/planner/plan/utils/WindowJoinUtil.scala | 3 +-
.../file/table/FileSystemTableSourceTest.xml | 2 +-
.../apache/flink/table/api/stream/ExplainTest.xml | 8 +-
.../table/planner/plan/batch/sql/CalcTest.xml | 24 +--
.../planner/plan/batch/sql/DagOptimizationTest.xml | 14 +-
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 16 +-
.../plan/batch/sql/LegacyTableSourceTest.xml | 4 +-
.../plan/batch/sql/MultipleInputCreationTest.xml | 40 ++---
.../plan/batch/sql/PartitionableSinkTest.xml | 6 +-
.../plan/batch/sql/PartitionableSourceTest.xml | 18 +-
.../table/planner/plan/batch/sql/RankTest.xml | 6 +-
.../planner/plan/batch/sql/RemoveCollationTest.xml | 12 +-
.../planner/plan/batch/sql/RemoveShuffleTest.xml | 62 +++----
.../planner/plan/batch/sql/SetOperatorsTest.xml | 6 +-
.../planner/plan/batch/sql/SubplanReuseTest.xml | 34 ++--
.../planner/plan/batch/sql/TableSourceTest.xml | 2 +-
.../table/planner/plan/batch/sql/UnionTest.xml | 4 +-
.../table/planner/plan/batch/sql/ValuesTest.xml | 8 +-
.../batch/sql/agg/AggregateReduceGroupingTest.xml | 20 +--
.../plan/batch/sql/agg/DistinctAggregateTest.xml | 62 +++----
.../planner/plan/batch/sql/agg/GroupWindowTest.xml | 18 +-
.../plan/batch/sql/agg/GroupingSetsTest.xml | 44 ++---
.../plan/batch/sql/agg/HashAggregateTest.xml | 12 +-
.../plan/batch/sql/agg/OverAggregateTest.xml | 22 +--
.../plan/batch/sql/agg/SortAggregateTest.xml | 12 +-
.../plan/batch/sql/join/BroadcastHashJoinTest.xml | 2 +-
.../sql/join/BroadcastHashSemiAntiJoinTest.xml | 22 +--
.../planner/plan/batch/sql/join/LookupJoinTest.xml | 4 +-
.../plan/batch/sql/join/NestedLoopJoinTest.xml | 2 +-
.../batch/sql/join/NestedLoopSemiAntiJoinTest.xml | 28 +--
.../plan/batch/sql/join/SemiAntiJoinTest.xml | 28 +--
.../sql/join/ShuffledHashSemiAntiJoinTest.xml | 24 +--
.../plan/batch/sql/join/SingleRowJoinTest.xml | 2 +-
.../plan/batch/sql/join/SortMergeJoinTest.xml | 2 +-
.../batch/sql/join/SortMergeSemiAntiJoinTest.xml | 24 +--
.../planner/plan/batch/table/AggregateTest.xml | 6 +-
.../table/planner/plan/batch/table/CalcTest.xml | 4 +-
.../planner/plan/batch/table/CorrelateTest.xml | 4 +-
.../planner/plan/batch/table/GroupWindowTest.xml | 2 +-
.../planner/plan/batch/table/SetOperatorsTest.xml | 14 +-
.../stringexpr/CorrelateStringExpressionTest.xml | 2 +-
.../batch/table/stringexpr/SetOperatorsTest.xml | 4 +-
.../planner/plan/common/PartialInsertTest.xml | 52 +++---
.../planner/plan/common/ViewsExpandingTest.xml | 4 +-
.../CalcJsonPlanTest_jsonplan/testComplexCalc.out | 4 +-
.../testCrossJoinOverrideParameters.out | 2 +-
...tDistinctAggCalls[isMiniBatchEnabled=false].out | 2 +-
...stDistinctAggCalls[isMiniBatchEnabled=true].out | 2 +-
...gCallsWithGroupBy[isMiniBatchEnabled=false].out | 2 +-
...ggCallsWithGroupBy[isMiniBatchEnabled=true].out | 2 +-
...AggWithoutGroupBy[isMiniBatchEnabled=false].out | 2 +-
...eAggWithoutGroupBy[isMiniBatchEnabled=true].out | 2 +-
...erDefinedAggCalls[isMiniBatchEnabled=false].out | 2 +-
...serDefinedAggCalls[isMiniBatchEnabled=true].out | 2 +-
.../testJoinTemporalTable.out | 2 +-
...testJoinTemporalTableWithProjectionPushDown.out | 2 +-
.../testProcTimeBoundedNonPartitionedRangeOver.out | 4 +-
.../testProcTimeBoundedPartitionedRangeOver.out | 4 +-
...undedPartitionedRowsOverWithBuiltinProctime.out | 4 +-
.../testProcTimeUnboundedPartitionedRangeOver.out | 2 +-
...stProctimeBoundedDistinctPartitionedRowOver.out | 2 +-
...edDistinctWithNonDistinctPartitionedRowOver.out | 2 +-
.../tesPythonAggCallsWithGroupBy.out | 2 +-
.../testProcTimeBoundedNonPartitionedRangeOver.out | 2 +-
.../testProcTimeBoundedPartitionedRangeOver.out | 2 +-
...undedPartitionedRowsOverWithBuiltinProctime.out | 2 +-
.../testProcTimeUnboundedPartitionedRangeOver.out | 2 +-
.../testRowTimeBoundedPartitionedRowsOver.out | 2 +-
.../testPartitioning.out | 2 +-
.../testFilterPushDown.out | 2 +-
.../testPartitionPushDown.out | 2 +-
.../ValuesJsonPlanTest_jsonplan/testValues.out | 2 +-
.../testDistinctSplitEnabled.out | 2 +-
.../logical/AggregateReduceGroupingRuleTest.xml | 22 +--
.../rules/logical/CorrelateSortToRankRuleTest.xml | 178 +++++++++---------
.../logical/DecomposeGroupingSetsRuleTest.xml | 12 +-
.../rules/logical/ExpressionReductionRulesTest.xml | 4 +-
...nkAggregateExpandDistinctAggregatesRuleTest.xml | 62 +++----
.../rules/logical/FlinkAggregateRemoveRuleTest.xml | 12 +-
.../plan/rules/logical/FlinkCalcMergeRuleTest.xml | 4 +-
.../FlinkLogicalRankRuleForConstantRangeTest.xml | 4 +-
.../FlinkLogicalRankRuleForRangeEndTest.xml | 4 +-
.../PushFilterInCalcIntoTableSourceRuleTest.xml | 8 +-
.../PushWatermarkIntoTableSourceScanRuleTest.xml | 6 +-
.../plan/rules/logical/PythonCalcSplitRuleTest.xml | 40 ++---
.../logical/RankNumberColumnRemoveRuleTest.xml | 2 +-
.../logical/RemoveSingleAggregateRuleTest.xml | 24 +--
.../RemoveUnreachableCoalesceArgumentsRuleTest.xml | 4 +-
.../plan/rules/logical/SplitAggregateRuleTest.xml | 8 +-
.../TemporalJoinRewriteWithUniqueKeyRuleTest.xml | 4 +-
.../PushLocalAggIntoTableSourceScanRuleTest.xml | 4 +-
.../batch/RemoveRedundantLocalHashAggRuleTest.xml | 4 +-
.../batch/RemoveRedundantLocalSortAggRuleTest.xml | 6 +-
.../physical/stream/ChangelogModeInferenceTest.xml | 12 +-
.../table/planner/plan/stream/sql/CalcTest.xml | 24 +--
.../plan/stream/sql/DagOptimizationTest.xml | 38 ++--
.../planner/plan/stream/sql/DeduplicateTest.xml | 10 +-
.../plan/stream/sql/FilterableSourceTest.xml | 200 ++++++++++-----------
.../plan/stream/sql/LegacyTableSourceTest.xml | 4 +-
.../planner/plan/stream/sql/MatchRecognizeTest.xml | 6 +-
.../plan/stream/sql/MiniBatchIntervalInferTest.xml | 8 +-
.../plan/stream/sql/PartitionableSinkTest.xml | 4 +-
.../plan/stream/sql/PartitionableSourceTest.xml | 18 +-
.../table/planner/plan/stream/sql/RankTest.xml | 8 +-
.../stream/sql/RelTimeIndicatorConverterTest.xml | 18 +-
.../planner/plan/stream/sql/SetOperatorsTest.xml | 6 +-
.../plan/stream/sql/SourceWatermarkTest.xml | 2 +-
.../planner/plan/stream/sql/SubplanReuseTest.xml | 14 +-
.../planner/plan/stream/sql/TableScanTest.xml | 6 +-
.../planner/plan/stream/sql/TableSinkTest.xml | 2 +-
.../planner/plan/stream/sql/TableSourceTest.xml | 2 +-
.../table/planner/plan/stream/sql/UnionTest.xml | 8 +-
.../table/planner/plan/stream/sql/ValuesTest.xml | 8 +-
.../plan/stream/sql/WindowDeduplicateTest.xml | 8 +-
.../planner/plan/stream/sql/agg/AggregateTest.xml | 12 +-
.../plan/stream/sql/agg/DistinctAggregateTest.xml | 12 +-
.../plan/stream/sql/agg/GroupWindowTest.xml | 22 +--
.../plan/stream/sql/agg/GroupingSetsTest.xml | 40 ++---
.../stream/sql/agg/IncrementalAggregateTest.xml | 4 +-
.../plan/stream/sql/agg/OverAggregateTest.xml | 22 +--
.../plan/stream/sql/agg/TwoStageAggregateTest.xml | 6 +-
.../plan/stream/sql/agg/WindowAggregateTest.xml | 24 +--
.../plan/stream/sql/join/IntervalJoinTest.xml | 30 ++--
.../planner/plan/stream/sql/join/JoinTest.xml | 16 +-
.../plan/stream/sql/join/LookupJoinTest.xml | 48 ++---
.../plan/stream/sql/join/SemiAntiJoinTest.xml | 28 +--
.../plan/stream/sql/join/TemporalJoinTest.xml | 34 ++--
.../plan/stream/sql/join/WindowJoinTest.xml | 36 ++--
.../planner/plan/stream/table/AggregateTest.xml | 6 +-
.../table/planner/plan/stream/table/CalcTest.xml | 6 +-
.../plan/stream/table/ColumnFunctionsTest.xml | 6 +-
.../planner/plan/stream/table/CorrelateTest.xml | 10 +-
.../planner/plan/stream/table/GroupWindowTest.xml | 10 +-
.../plan/stream/table/OverAggregateTest.xml | 28 +--
.../planner/plan/stream/table/SetOperatorsTest.xml | 2 +-
.../plan/stream/table/TableAggregateTest.xml | 2 +-
.../stream/table/TemporalTableFunctionJoinTest.xml | 4 +-
.../plan/stream/table/TwoStageAggregateTest.xml | 4 +-
.../table/planner/plan/stream/table/ValuesTest.xml | 62 +++----
.../planner/plan/utils/FlinkRelOptUtilTest.scala | 3 +-
155 files changed, 1254 insertions(+), 1109 deletions(-)
