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 1170f80 [FLINK-17441][kinesis][test-stability] Updating test to
assert if timeout occurs waiting for records (#15160)
add b0ffd84 [FLINK-21730][table-planner-blink] Introduce
ExecNodeTranslator
No new revisions were added by this update.
Summary of changes:
.../table/planner/plan/nodes/exec/ExecNode.java | 15 ++-------
.../planner/plan/nodes/exec/ExecNodeBase.java | 7 ++++
.../plan/nodes/exec/ExecNodeTranslator.java} | 26 +++++++--------
.../exec/MultipleTransformationTranslator.java | 13 +++-----
.../nodes/exec/SingleTransformationTranslator.java | 14 ++++----
.../exec/batch/BatchExecBoundedStreamScan.java | 3 +-
.../nodes/exec/batch/BatchExecHashAggregate.java | 3 +-
.../plan/nodes/exec/batch/BatchExecHashJoin.java | 28 +++++++---------
.../exec/batch/BatchExecHashWindowAggregate.java | 3 +-
.../plan/nodes/exec/batch/BatchExecLimit.java | 18 ++++-------
.../nodes/exec/batch/BatchExecMultipleInput.java | 3 +-
.../nodes/exec/batch/BatchExecNestedLoopJoin.java | 24 +++++---------
.../plan/nodes/exec/batch/BatchExecNode.java | 2 ++
.../exec/batch/BatchExecOverAggregateBase.java | 3 +-
.../exec/batch/BatchExecPythonGroupAggregate.java | 3 +-
.../batch/BatchExecPythonGroupWindowAggregate.java | 3 +-
.../plan/nodes/exec/batch/BatchExecRank.java | 20 ++++--------
.../plan/nodes/exec/batch/BatchExecSort.java | 22 ++++---------
.../nodes/exec/batch/BatchExecSortAggregate.java | 3 +-
.../plan/nodes/exec/batch/BatchExecSortLimit.java | 23 ++++++--------
.../nodes/exec/batch/BatchExecSortMergeJoin.java | 27 ++++++----------
.../exec/batch/BatchExecSortWindowAggregate.java | 3 +-
.../plan/nodes/exec/common/CommonExecCalc.java | 23 ++++++--------
.../nodes/exec/common/CommonExecCorrelate.java | 37 ++++++++++------------
.../plan/nodes/exec/common/CommonExecExchange.java | 5 ++-
.../plan/nodes/exec/common/CommonExecExpand.java | 23 ++++++--------
.../nodes/exec/common/CommonExecLegacySink.java | 4 ++-
.../common/CommonExecLegacyTableSourceScan.java | 4 ++-
.../nodes/exec/common/CommonExecLookupJoin.java | 22 ++++++-------
.../nodes/exec/common/CommonExecPythonCalc.java | 8 ++---
.../exec/common/CommonExecPythonCorrelate.java | 8 ++---
.../plan/nodes/exec/common/CommonExecSink.java | 4 ++-
.../exec/common/CommonExecTableSourceScan.java | 4 ++-
.../plan/nodes/exec/common/CommonExecUnion.java | 4 ++-
.../plan/nodes/exec/common/CommonExecValues.java | 4 ++-
.../exec/stream/StreamExecChangelogNormalize.java | 8 ++---
.../exec/stream/StreamExecDataStreamScan.java | 3 +-
.../nodes/exec/stream/StreamExecDeduplicate.java | 8 ++---
.../exec/stream/StreamExecDropUpdateBefore.java | 3 +-
.../stream/StreamExecGlobalGroupAggregate.java | 8 ++---
.../exec/stream/StreamExecGroupAggregate.java | 8 ++---
.../exec/stream/StreamExecGroupTableAggregate.java | 8 ++---
.../stream/StreamExecGroupWindowAggregate.java | 8 ++---
.../StreamExecIncrementalGroupAggregate.java | 8 ++---
.../nodes/exec/stream/StreamExecIntervalJoin.java | 3 +-
.../plan/nodes/exec/stream/StreamExecJoin.java | 9 ++----
.../exec/stream/StreamExecLocalGroupAggregate.java | 23 +++++---------
.../plan/nodes/exec/stream/StreamExecMatch.java | 4 ++-
.../exec/stream/StreamExecMiniBatchAssigner.java | 3 +-
.../plan/nodes/exec/stream/StreamExecNode.java | 2 ++
.../nodes/exec/stream/StreamExecOverAggregate.java | 7 ++--
.../stream/StreamExecPythonGroupAggregate.java | 8 ++---
.../StreamExecPythonGroupTableAggregate.java | 8 ++---
.../StreamExecPythonGroupWindowAggregate.java | 7 ++--
.../exec/stream/StreamExecPythonOverAggregate.java | 7 ++--
.../plan/nodes/exec/stream/StreamExecRank.java | 9 ++----
.../plan/nodes/exec/stream/StreamExecSort.java | 19 ++++-------
.../nodes/exec/stream/StreamExecTemporalJoin.java | 8 ++---
.../nodes/exec/stream/StreamExecTemporalSort.java | 3 +-
.../exec/stream/StreamExecWatermarkAssigner.java | 3 +-
.../exec/stream/StreamExecWindowAggregate.java | 8 ++---
61 files changed, 249 insertions(+), 360 deletions(-)
copy
flink-table/{flink-table-api-java/src/main/java/org/apache/flink/table/operations/ModifyOperation.java
=>
flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeTranslator.java}
(62%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/state/SnapshotResources.java
=>
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/MultipleTransformationTranslator.java
(70%)
copy flink-core/src/main/java/org/apache/flink/util/IterableIterator.java =>
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/SingleTransformationTranslator.java
(64%)
