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 759d734 [hotfix][coordination] Remove resetForNewExecution from
ExecutionJobVertex
add 842f5cd [FLINK-21041][table-planner-blink] Introduce ExecNodeGraph to
wrap the ExecNode topology
No new revisions were added by this update.
Summary of changes:
.../connectors/hive/HiveTableSourceITCase.java | 13 ++++++++-----
.../planner/plan/nodes/exec/ExecNodeGraph.java | 20 ++++++++------------
...hGenerator.java => ExecNodeGraphGenerator.java} | 12 ++++++------
.../plan/nodes/exec/processor/DAGProcessor.java | 8 +++-----
.../exec/processor/DeadlockBreakupProcessor.java | 15 +++++++--------
.../MultipleInputNodeCreationProcessor.java | 10 ++++++----
.../plan/nodes/exec/utils/ExecNodePlanDumper.java | 9 +++++++++
.../table/planner/delegation/BatchPlanner.scala | 22 ++++++++++------------
.../table/planner/delegation/PlannerBase.scala | 22 +++++++++++-----------
.../table/planner/delegation/StreamPlanner.scala | 13 ++++++-------
.../MultipleInputNodeCreationProcessorTest.java | 10 +++++-----
.../flink/table/planner/utils/TableTestBase.scala | 4 ++--
12 files changed, 81 insertions(+), 77 deletions(-)
copy
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/SplitsAddition.java
=>
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeGraph.java
(68%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/{ExecGraphGenerator.java
=> ExecNodeGraphGenerator.java} (90%)
