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 d759863 [FLINK-20534] Add Flink 1.12 MigrationVersion
add 314b4d0 [FLINK-20490][table-planner-blink] Don't share inputs between
FlinkPhysicalRel and ExecNode
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/ExecGraphGenerator.java | 86 ++++++++++++++++++++++
.../MultipleInputNodeCreationProcessor.java | 14 +++-
.../utils/InputPriorityConflictResolver.java | 4 +
.../table/planner/delegation/PlannerBase.scala | 5 +-
.../planner/plan/nodes/exec/ExecNodeBase.scala | 22 ++++++
.../plan/nodes/physical/FlinkPhysicalRel.scala | 1 -
.../plan/nodes/physical/MultipleInputRel.scala | 12 ++-
.../batch/BatchExecBoundedStreamScan.scala | 10 +--
.../nodes/physical/batch/BatchExecCalcBase.scala | 11 +--
.../physical/batch/BatchExecCorrelateBase.scala | 11 +--
.../nodes/physical/batch/BatchExecExchange.scala | 11 +--
.../nodes/physical/batch/BatchExecExpand.scala | 12 +--
.../batch/BatchExecHashAggregateBase.scala | 15 +---
.../nodes/physical/batch/BatchExecHashJoin.scala | 11 +--
.../batch/BatchExecHashWindowAggregateBase.scala | 15 +---
.../batch/BatchExecIntermediateTableScan.scala | 1 -
.../nodes/physical/batch/BatchExecLegacySink.scala | 11 +--
.../batch/BatchExecLegacyTableSourceScan.scala | 10 +--
.../plan/nodes/physical/batch/BatchExecLimit.scala | 11 +--
.../nodes/physical/batch/BatchExecLookupJoin.scala | 12 +--
.../physical/batch/BatchExecMultipleInput.scala | 4 -
.../physical/batch/BatchExecNestedLoopJoin.scala | 11 +--
.../batch/BatchExecOverAggregateBase.scala | 11 +--
.../batch/BatchExecPythonGroupAggregate.scala | 23 ++----
.../BatchExecPythonGroupWindowAggregate.scala | 11 +--
.../plan/nodes/physical/batch/BatchExecRank.scala | 11 +--
.../plan/nodes/physical/batch/BatchExecSink.scala | 11 +--
.../plan/nodes/physical/batch/BatchExecSort.scala | 11 +--
.../batch/BatchExecSortAggregateBase.scala | 15 +---
.../nodes/physical/batch/BatchExecSortLimit.scala | 11 +--
.../physical/batch/BatchExecSortMergeJoin.scala | 11 +--
.../batch/BatchExecSortWindowAggregateBase.scala | 15 +---
.../physical/batch/BatchExecTableSourceScan.scala | 10 +--
.../plan/nodes/physical/batch/BatchExecUnion.scala | 11 +--
.../nodes/physical/batch/BatchExecValues.scala | 10 +--
.../nodes/physical/stream/StreamExecCalcBase.scala | 17 +----
.../stream/StreamExecChangelogNormalize.scala | 14 +---
.../physical/stream/StreamExecCorrelateBase.scala | 14 +---
.../physical/stream/StreamExecDataStreamScan.scala | 12 +--
.../physical/stream/StreamExecDeduplicate.scala | 12 +--
.../stream/StreamExecDropUpdateBefore.scala | 17 +----
.../nodes/physical/stream/StreamExecExchange.scala | 14 +---
.../nodes/physical/stream/StreamExecExpand.scala | 14 +---
.../stream/StreamExecGlobalGroupAggregate.scala | 14 +---
.../physical/stream/StreamExecGroupAggregate.scala | 12 +--
.../stream/StreamExecGroupTableAggregate.scala | 12 +--
.../StreamExecGroupWindowAggregateBase.scala | 13 +---
.../StreamExecIncrementalGroupAggregate.scala | 12 +--
.../stream/StreamExecIntermediateTableScan.scala | 1 -
.../physical/stream/StreamExecIntervalJoin.scala | 13 +---
.../nodes/physical/stream/StreamExecJoin.scala | 14 +---
.../physical/stream/StreamExecLegacySink.scala | 16 +---
.../stream/StreamExecLegacyTableSourceScan.scala | 17 +----
.../nodes/physical/stream/StreamExecLimit.scala | 18 +----
.../stream/StreamExecLocalGroupAggregate.scala | 12 +--
.../physical/stream/StreamExecLookupJoin.scala | 14 +---
.../nodes/physical/stream/StreamExecMatch.scala | 12 +--
.../stream/StreamExecMiniBatchAssigner.scala | 14 +---
.../physical/stream/StreamExecMultipleInput.scala | 8 --
.../stream/StreamExecOverAggregateBase.scala | 15 +---
.../stream/StreamExecPythonGroupAggregate.scala | 14 +---
.../nodes/physical/stream/StreamExecRank.scala | 12 +--
.../nodes/physical/stream/StreamExecSink.scala | 12 +--
.../nodes/physical/stream/StreamExecSort.scala | 19 +----
.../physical/stream/StreamExecSortLimit.scala | 14 +---
.../stream/StreamExecTableSourceScan.scala | 16 +---
.../physical/stream/StreamExecTemporalJoin.scala | 14 +---
.../physical/stream/StreamExecTemporalSort.scala | 20 +----
.../nodes/physical/stream/StreamExecUnion.scala | 12 +--
.../nodes/physical/stream/StreamExecValues.scala | 14 +---
.../stream/StreamExecWatermarkAssigner.scala | 14 +---
.../planner/plan/utils/ExecNodePlanDumper.scala | 29 ++++++--
.../planner/plan/utils/RelTreeWriterImpl.scala | 12 +--
.../MultipleInputNodeCreationProcessorTest.java | 10 ++-
.../utils/InputPriorityConflictResolverTest.java | 1 +
75 files changed, 240 insertions(+), 765 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecGraphGenerator.java
