This is an automated email from the ASF dual-hosted git repository. jark pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 421f0a5 [FLINK-13523][table-planner-blink] Refactor AVG aggregate function to keep it compatible with old planner add c649c8b [FLINK-13587][table-planner-blink] Introduces a framework to reuse code of "explainTerms" to generate operator names add bf37130 [FLINK-13587][table-planner-blink] Fix some operator names are not set in blink planner No new revisions were added by this update. Summary of changes: .../plan/utils/RelDescriptionWriterImpl.java | 107 +++++++++++++++++ .../planner/codegen/CorrelateCodeGenerator.scala | 7 +- .../table/planner/delegation/BatchPlanner.scala | 2 +- .../table/planner/delegation/StreamPlanner.scala | 2 +- .../table/planner/plan/nodes/FlinkRelNode.scala | 20 +++- .../table/planner/plan/nodes/calcite/Expand.scala | 22 ++-- .../planner/plan/nodes/common/CommonCalc.scala | 7 +- .../plan/nodes/common/CommonLookupJoin.scala | 6 +- .../plan/nodes/common/CommonPhysicalJoin.scala | 7 +- .../plan/nodes/physical/batch/BatchExecCalc.scala | 3 +- .../nodes/physical/batch/BatchExecCorrelate.scala | 4 +- .../nodes/physical/batch/BatchExecExpand.scala | 3 +- .../batch/BatchExecGroupAggregateBase.scala | 14 +-- .../physical/batch/BatchExecHashAggregate.scala | 5 - .../batch/BatchExecHashAggregateBase.scala | 4 +- .../nodes/physical/batch/BatchExecHashJoin.scala | 12 +- .../batch/BatchExecHashWindowAggregate.scala | 4 - .../batch/BatchExecHashWindowAggregateBase.scala | 4 +- .../plan/nodes/physical/batch/BatchExecLimit.scala | 7 +- .../batch/BatchExecLocalHashAggregate.scala | 2 - .../batch/BatchExecLocalHashWindowAggregate.scala | 4 - .../batch/BatchExecLocalSortAggregate.scala | 3 - .../batch/BatchExecLocalSortWindowAggregate.scala | 2 - .../physical/batch/BatchExecNestedLoopJoin.scala | 13 +- .../physical/batch/BatchExecOverAggregate.scala | 6 +- .../plan/nodes/physical/batch/BatchExecRank.scala | 10 +- .../plan/nodes/physical/batch/BatchExecSort.scala | 2 +- .../physical/batch/BatchExecSortAggregate.scala | 6 - .../batch/BatchExecSortAggregateBase.scala | 4 +- .../nodes/physical/batch/BatchExecSortLimit.scala | 9 +- .../physical/batch/BatchExecSortMergeJoin.scala | 10 +- .../batch/BatchExecSortWindowAggregate.scala | 5 - .../batch/BatchExecSortWindowAggregateBase.scala | 4 +- .../nodes/physical/batch/BatchExecValues.scala | 1 + .../nodes/physical/stream/StreamExecCalc.scala | 2 +- .../physical/stream/StreamExecCorrelate.scala | 1 + .../physical/stream/StreamExecDeduplicate.scala | 13 +- .../nodes/physical/stream/StreamExecExpand.scala | 3 +- .../stream/StreamExecGlobalGroupAggregate.scala | 2 +- .../physical/stream/StreamExecGroupAggregate.scala | 2 +- .../stream/StreamExecGroupWindowAggregate.scala | 10 +- .../StreamExecIncrementalGroupAggregate.scala | 2 +- .../nodes/physical/stream/StreamExecJoin.scala | 9 +- .../nodes/physical/stream/StreamExecLimit.scala | 2 +- .../stream/StreamExecLocalGroupAggregate.scala | 2 +- .../nodes/physical/stream/StreamExecMatch.scala | 2 +- .../physical/stream/StreamExecOverAggregate.scala | 2 +- .../nodes/physical/stream/StreamExecRank.scala | 16 +-- .../nodes/physical/stream/StreamExecSort.scala | 2 +- .../physical/stream/StreamExecSortLimit.scala | 9 +- .../physical/stream/StreamExecTemporalJoin.scala | 8 +- .../physical/stream/StreamExecTemporalSort.scala | 4 +- .../nodes/physical/stream/StreamExecValues.scala | 1 + .../stream/StreamExecWatermarkAssigner.scala | 18 +-- .../physical/stream/StreamExecWindowJoin.scala | 11 +- .../planner/plan/utils/ExecNodePlanDumper.scala | 2 +- .../table/planner/plan/utils/FlinkRelOptUtil.scala | 2 +- .../table/planner/plan/utils/RelExplainUtil.scala | 81 +++---------- .../flink/table/planner/plan/utils/ScanUtil.scala | 5 +- .../resources/explain/testGetStatsFromCatalog.out | 6 +- .../apache/flink/table/api/batch/ExplainTest.xml | 104 ++++++++-------- .../apache/flink/table/api/stream/ExplainTest.xml | 132 ++++++++++----------- .../table/planner/plan/batch/sql/LimitTest.xml | 8 +- .../planner/plan/batch/sql/SetOperatorsTest.xml | 6 +- .../table/planner/plan/batch/sql/SortLimitTest.xml | 8 +- .../table/planner/plan/batch/sql/UnnestTest.xml | 20 ++-- .../table/planner/plan/batch/sql/ValuesTest.xml | 22 ++-- .../plan/batch/sql/join/BroadcastHashJoinTest.xml | 2 +- .../plan/batch/sql/join/NestedLoopJoinTest.xml | 6 +- .../plan/batch/sql/join/SortMergeJoinTest.xml | 2 +- .../logical/CalcPruneAggregateCallRuleTest.xml | 10 +- .../rules/logical/FlinkAggregateRemoveRuleTest.xml | 8 +- .../rules/logical/FlinkLimit0RemoveRuleTest.xml | 18 +-- .../rules/logical/FlinkPruneEmptyRulesTest.xml | 2 +- .../plan/rules/logical/LogicalUnnestRuleTest.xml | 20 ++-- .../logical/ProjectPruneAggregateCallRuleTest.xml | 4 +- .../logical/subquery/SubQuerySemiJoinTest.xml | 4 +- .../table/planner/plan/stream/sql/LimitTest.xml | 24 ++-- .../plan/stream/sql/MiniBatchIntervalInferTest.xml | 30 ++--- .../table/planner/plan/stream/sql/RankTest.xml | 4 +- .../planner/plan/stream/sql/SetOperatorsTest.xml | 6 +- .../planner/plan/stream/sql/SortLimitTest.xml | 32 ++--- .../table/planner/plan/stream/sql/UnnestTest.xml | 20 ++-- .../table/planner/plan/stream/sql/ValuesTest.xml | 22 ++-- .../planner/plan/stream/sql/join/JoinTest.xml | 2 +- .../plan/stream/sql/join/WindowJoinTest.xml | 2 +- .../flink/table/planner/utils/TableTestBase.scala | 26 ++-- 87 files changed, 507 insertions(+), 575 deletions(-) create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/utils/RelDescriptionWriterImpl.java