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 93c0855 [hotfix][connector-kafka] Deprecate old Kafka table sources
and sinks
add 37dbcac [FLINK-19623][table-planner] Introduce ExecEdge to describe
information on input edges for ExecNode (#13625)
No new revisions were added by this update.
Summary of changes:
.../table/planner/plan/nodes/exec/ExecEdge.java | 239 +++++++++++++++++++++
.../planner/plan/nodes/exec/BatchExecNode.scala | 10 +-
.../table/planner/plan/nodes/exec/ExecNode.scala | 12 +-
.../planner/plan/nodes/exec/StreamExecNode.scala | 12 +-
.../batch/BatchExecBoundedStreamScan.scala | 7 +-
.../nodes/physical/batch/BatchExecCalcBase.scala | 7 +-
.../physical/batch/BatchExecCorrelateBase.scala | 8 +-
.../nodes/physical/batch/BatchExecExchange.scala | 36 ++--
.../nodes/physical/batch/BatchExecExpand.scala | 8 +-
.../physical/batch/BatchExecHashAggregate.scala | 8 +-
.../nodes/physical/batch/BatchExecHashJoin.scala | 39 +++-
.../batch/BatchExecHashWindowAggregate.scala | 10 +-
.../nodes/physical/batch/BatchExecLegacySink.scala | 20 +-
.../batch/BatchExecLegacyTableSourceScan.scala | 8 +-
.../plan/nodes/physical/batch/BatchExecLimit.scala | 8 +-
.../batch/BatchExecLocalHashAggregate.scala | 14 +-
.../batch/BatchExecLocalHashWindowAggregate.scala | 6 +-
.../batch/BatchExecLocalSortAggregate.scala | 14 +-
.../batch/BatchExecLocalSortWindowAggregate.scala | 6 +-
.../nodes/physical/batch/BatchExecLookupJoin.scala | 8 +-
.../batch/BatchExecMultipleInputNode.scala | 17 +-
.../physical/batch/BatchExecNestedLoopJoin.scala | 34 ++-
.../batch/BatchExecOverAggregateBase.scala | 12 +-
.../batch/BatchExecPythonGroupAggregate.scala | 11 +-
.../BatchExecPythonGroupWindowAggregate.scala | 11 +-
.../plan/nodes/physical/batch/BatchExecRank.scala | 7 +-
.../plan/nodes/physical/batch/BatchExecSink.scala | 20 +-
.../plan/nodes/physical/batch/BatchExecSort.scala | 11 +-
.../physical/batch/BatchExecSortAggregate.scala | 14 +-
.../nodes/physical/batch/BatchExecSortLimit.scala | 11 +-
.../physical/batch/BatchExecSortMergeJoin.scala | 19 +-
.../batch/BatchExecSortWindowAggregate.scala | 8 +-
.../physical/batch/BatchExecTableSourceScan.scala | 7 +-
.../plan/nodes/physical/batch/BatchExecUnion.scala | 9 +-
.../nodes/physical/batch/BatchExecValues.scala | 7 +-
.../plan/reuse/DeadlockBreakupProcessor.scala | 167 +++++++-------
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 2 +-
.../planner/plan/batch/sql/SubplanReuseTest.xml | 2 +-
.../apache/flink/table/api/batch/ExplainTest.scala | 25 ++-
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 19 +-
40 files changed, 641 insertions(+), 252 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecEdge.java
