[flink] branch master updated (c059458 -> 2af346e)

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from c059458  [FLINK-25976][connectors/kinesis] Updating the default number of in flight records to 50
     add 2af346e  [FLINK-25932][table-planner] Add deterministic uid to every transformation created by StreamExecNode

No new revisions were added by this update.

Summary of changes:
 .../planner/plan/nodes/exec/ExecNodeBase.java      |  74 ++++++++---
 .../planner/plan/nodes/exec/ExecNodeContext.java   |  16 +++
 .../planner/plan/nodes/exec/ExecNodeMetadata.java  |   4 +-
 .../exec/batch/BatchExecBoundedStreamScan.java     |   4 +-
 .../nodes/exec/batch/BatchExecHashAggregate.java   |   4 +-
 .../plan/nodes/exec/batch/BatchExecHashJoin.java   |   4 +-
 .../exec/batch/BatchExecHashWindowAggregate.java   |   4 +-
 .../exec/batch/BatchExecLegacyTableSourceScan.java |   4 +-
 .../plan/nodes/exec/batch/BatchExecLimit.java      |   4 +-
 .../nodes/exec/batch/BatchExecMultipleInput.java   |   5 +-
 .../nodes/exec/batch/BatchExecNestedLoopJoin.java  |   4 +-
 .../nodes/exec/batch/BatchExecOverAggregate.java   |   4 +-
 .../exec/batch/BatchExecPythonGroupAggregate.java  |   4 +-
 .../batch/BatchExecPythonGroupWindowAggregate.java |   4 +-
 .../exec/batch/BatchExecPythonOverAggregate.java   |   4 +-
 .../plan/nodes/exec/batch/BatchExecRank.java       |   4 +-
 .../plan/nodes/exec/batch/BatchExecSort.java       |   4 +-
 .../nodes/exec/batch/BatchExecSortAggregate.java   |   4 +-
 .../plan/nodes/exec/batch/BatchExecSortLimit.java  |   4 +-
 .../nodes/exec/batch/BatchExecSortMergeJoin.java   |   4 +-
 .../exec/batch/BatchExecSortWindowAggregate.java   |   4 +-
 .../plan/nodes/exec/common/CommonExecCalc.java     |   6 +-
 .../nodes/exec/common/CommonExecCorrelate.java     |   5 +-
 .../plan/nodes/exec/common/CommonExecExpand.java   |   5 +-
 .../nodes/exec/common/CommonExecLegacySink.java    |   4 +-
 .../nodes/exec/common/CommonExecLookupJoin.java    |   5 +-
 .../nodes/exec/common/CommonExecPythonCalc.java    |   5 +-
 .../exec/common/CommonExecPythonCorrelate.java     |   5 +-
 .../plan/nodes/exec/common/CommonExecSink.java     |  77 +++++++----
 .../exec/common/CommonExecTableSourceScan.java     |  25 ++--
 .../plan/nodes/exec/common/CommonExecValues.java   |   6 +-
 .../exec/common/CommonExecWindowTableFunction.java |   5 +-
 .../plan/nodes/exec/stream/StreamExecCalc.java     |   1 +
 .../exec/stream/StreamExecChangelogNormalize.java  |   6 +-
 .../nodes/exec/stream/StreamExecCorrelate.java     |   1 +
 .../exec/stream/StreamExecDataStreamScan.java      |   7 +-
 .../nodes/exec/stream/StreamExecDeduplicate.java   |   7 +-
 .../exec/stream/StreamExecDropUpdateBefore.java    |   7 +-
 .../plan/nodes/exec/stream/StreamExecExchange.java |   5 +
 .../plan/nodes/exec/stream/StreamExecExpand.java   |   1 +
 .../stream/StreamExecGlobalGroupAggregate.java     |   9 +-
 .../stream/StreamExecGlobalWindowAggregate.java    |   8 +-
 .../exec/stream/StreamExecGroupAggregate.java      |   7 +-
 .../exec/stream/StreamExecGroupTableAggregate.java |   7 +-
 .../stream/StreamExecGroupWindowAggregate.java     |  13 +-
 .../StreamExecIncrementalGroupAggregate.java       |  10 +-
 .../nodes/exec/stream/StreamExecIntervalJoin.java  |  44 +++++--
 .../plan/nodes/exec/stream/StreamExecJoin.java     |   7 +-
 .../stream/StreamExecLegacyTableSourceScan.java    |   6 +-
 .../plan/nodes/exec/stream/StreamExecLimit.java    |   1 +
 .../exec/stream/StreamExecLocalGroupAggregate.java |   8 +-
 .../stream/StreamExecLocalWindowAggregate.java     |   8 +-
 .../nodes/exec/stream/StreamExecLookupJoin.java    |   1 +
 .../plan/nodes/exec/stream/StreamExecMatch.java    |  21 ++-
 .../exec/stream/StreamExecMiniBatchAssigner.java   |   7 +-
 .../nodes/exec/stream/StreamExecOverAggregate.java |   7 +-
 .../nodes/exec/stream/StreamExecPythonCalc.java    |   1 +
 .../exec/stream/StreamExecPythonCorrelate.java     |   1 +
 .../stream/StreamExecPythonGroupAggregate.java     |   7 +-
 .../StreamExecPythonGroupTableAggregate.java       |   6 +-
 .../StreamExecPythonGroupWindowAggregate.java      |   9 +-
 .../exec/stream/StreamExecPythonOverAggregate.java |   7 +-
 .../plan/nodes/exec/stream/StreamExecRank.java     |   6 +-
 .../plan/nodes/exec/stream/StreamExecSink.java     |   7 +
 .../plan/nodes/exec/stream/StreamExecSort.java     |   5 +-
 .../nodes/exec/stream/StreamExecSortLimit.java     |   1 +
 .../exec/stream/StreamExecTableSourceScan.java     |   1 +
 .../nodes/exec/stream/StreamExecTemporalJoin.java  |   7 +-
 .../nodes/exec/stream/StreamExecTemporalSort.java  |   9 +-
 .../plan/nodes/exec/stream/StreamExecValues.java   |   1 +
 .../exec/stream/StreamExecWatermarkAssigner.java   |   8 +-
 .../exec/stream/StreamExecWindowAggregate.java     |   7 +-
 .../exec/stream/StreamExecWindowDeduplicate.java   |   6 +-
 .../nodes/exec/stream/StreamExecWindowJoin.java    |   8 +-
 .../nodes/exec/stream/StreamExecWindowRank.java    |   7 +-
 .../exec/stream/StreamExecWindowTableFunction.java |   1 +
 .../plan/nodes/exec/utils/ExecNodeUtil.java        | 142 ++++++++++++++++++---
 .../nodes/exec/utils/TransformationMetadata.java   |  69 ++++++++++
 .../planner/codegen/CorrelateCodeGenerator.scala   |   8 +-
 79 files changed, 623 insertions(+), 215 deletions(-)
 create mode 100644 flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/TransformationMetadata.java