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 c7084b3 [FLINK-11719] Make starting and stopping of JobMaster
services symmetric
add 7f279ed [FLINK-20719][table-planner-blink] Change BatchExecNode &
StreamExecNode to interface and make each node extended from ExecNodeBase
directly
No new revisions were added by this update.
Summary of changes:
.../plan/nodes/exec/ExecGraphGenerator.java | 2 +-
.../planner/plan/nodes/exec/ExecNodeBase.java | 11 +--
.../exec/batch/BatchExecBoundedStreamScan.java | 10 ++-
.../plan/nodes/exec/batch/BatchExecCalc.java | 25 +------
.../plan/nodes/exec/batch/BatchExecExchange.java | 9 +--
.../exec/batch/BatchExecLegacyTableSourceScan.java | 70 +++++------------
.../nodes/exec/batch/BatchExecMultipleInput.java | 9 ++-
.../plan/nodes/exec/batch/BatchExecNode.java | 14 +---
.../nodes/exec/batch/BatchExecTableSourceScan.java | 17 +----
.../plan/nodes/exec/common/CommonExecCalc.java | 36 ++++++---
.../plan/nodes/exec/common/CommonExecExchange.java | 15 +++-
.../common/CommonExecLegacyTableSourceScan.java | 87 ++++++++++++++++++----
.../exec/common/CommonExecTableSourceScan.java | 35 ++++++---
.../plan/nodes/exec/stream/StreamExecCalc.java | 25 +------
.../exec/stream/StreamExecChangelogNormalize.java | 9 ++-
.../exec/stream/StreamExecDataStreamScan.java | 10 ++-
.../plan/nodes/exec/stream/StreamExecExchange.java | 10 +--
.../stream/StreamExecLegacyTableSourceScan.java | 57 ++++----------
.../nodes/exec/stream/StreamExecMultipleInput.java | 9 ++-
.../plan/nodes/exec/stream/StreamExecNode.java | 14 +---
.../exec/stream/StreamExecTableSourceScan.java | 17 +----
.../exec/stream/StreamExecWatermarkAssigner.java | 9 ++-
.../nodes/exec/batch/BatchExecPythonCalc.scala | 9 ++-
.../nodes/exec/stream/StreamExecPythonCalc.scala | 10 +--
24 files changed, 242 insertions(+), 277 deletions(-)
