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 de9cf86 [hotfix][state backend] Put the delegating log to
ChangelogStateBackend constructor
add b644af8 [FLINK-21890][table-planner-blink] Rename DAGProcessor to
ExecNodeGraphProcessor
No new revisions were added by this update.
Summary of changes:
.../exec/processor/DeadlockBreakupProcessor.java | 8 ++++----
...{DAGProcessor.java => ExecNodeGraphProcessor.java} | 9 ++++++---
.../processor/MultipleInputNodeCreationProcessor.java | 10 +++++-----
.../{DAGProcessContext.java => ProcessorContext.java} | 7 ++++---
.../flink/table/planner/delegation/BatchPlanner.scala | 19 +++++++------------
.../flink/table/planner/delegation/PlannerBase.scala | 17 +++++++++++++----
.../table/planner/delegation/StreamPlanner.scala | 3 +++
.../MultipleInputNodeCreationProcessorTest.java | 2 +-
8 files changed, 43 insertions(+), 32 deletions(-)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/{DAGProcessor.java
=> ExecNodeGraphProcessor.java} (81%)
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/{DAGProcessContext.java
=> ProcessorContext.java} (84%)
