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 67203f7 [FLINK-20582][docs] Fix typos in "CREATE Statements" page
add aab59c2 [FLINK-20668][table-planner-blink] Introduce
translateToExecNode method for FlinkPhysicalRel
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/ExecGraphGenerator.java | 78 ++--------------------
.../planner/plan/nodes/exec/ExecNodeBase.java | 19 ++++--
.../plan/nodes/exec/batch/BatchExecExchange.java | 11 ++-
.../nodes/exec/batch/BatchExecMultipleInput.java | 3 +-
.../plan/nodes/exec/batch/BatchExecNode.java | 3 +-
.../MultipleInputNodeCreationProcessor.java | 12 ++--
.../utils/InputPriorityConflictResolver.java | 10 +--
.../plan/nodes/exec/stream/StreamExecExchange.java | 3 +-
.../nodes/exec/stream/StreamExecMultipleInput.java | 9 +--
.../plan/nodes/exec/stream/StreamExecNode.java | 3 +-
.../table/planner/delegation/PlannerBase.scala | 2 +-
.../plan/nodes/physical/FlinkPhysicalRel.scala | 15 +++++
.../physical/batch/BatchPhysicalExchange.scala | 41 ++++++++++++
.../physical/common/CommonPhysicalExchange.scala | 26 +++++++-
.../physical/stream/StreamPhysicalExchange.scala | 10 +++
.../MultipleInputNodeCreationProcessorTest.java | 2 +-
.../utils/InputPriorityConflictResolverTest.java | 5 +-
17 files changed, 136 insertions(+), 116 deletions(-)
