[flink] branch master updated (e8a91fd -> 5365133)

[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 e8a91fd  [FLINK-25974] Removes cleanup future cancellation
     add 375b07b  [hotfix][table-planner] Avoid rawtypes warning in StreamExecDeduplicate
     add 0b59950  [hotfix][table-planner] Move non-temporal-sort config option to InternalConfigOptions
     add 68d936a  [hotfix][table-api][table-planner][docs] Move StreamExecDeduplicate options to ExecutionConfigOptions
     add 16ed0f4  [hotfix][table] Rename operator name option
     add 1ce16c5  [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata
     add 5365133  [hotfix][table-planner] Rename transformation name for StreamExec(Python)GroupWindowAggregate

No new revisions were added by this update.

Summary of changes:
 .../generated/execution_config_configuration.html  | 18 ++++++++
 .../generated/optimizer_config_configuration.html  |  6 ---
 .../52c5c6a1-204f-462d-9efa-4ffcb100fb4d           |  3 --
 .../flink/architecture/rules/TableApiRules.java    | 20 ++++----
 .../table/api/config/ExecutionConfigOptions.java   | 42 +++++++++++++++++
 .../table/api/config/OptimizerConfigOptions.java   |  8 ----
 .../planner/plan/nodes/exec/ExecNodeBase.java      |  6 +--
 .../planner/plan/nodes/exec/ExecNodeMetadata.java  |  8 ++++
 .../exec/stream/StreamExecChangelogNormalize.java  |  5 ++
 .../nodes/exec/stream/StreamExecDeduplicate.java   | 54 +++++++---------------
 .../stream/StreamExecGlobalGroupAggregate.java     |  5 ++
 .../stream/StreamExecGlobalWindowAggregate.java    |  1 +
 .../exec/stream/StreamExecGroupAggregate.java      |  5 ++
 .../stream/StreamExecGroupWindowAggregate.java     | 13 ++++--
 .../StreamExecIncrementalGroupAggregate.java       |  5 ++
 .../plan/nodes/exec/stream/StreamExecLimit.java    |  1 +
 .../exec/stream/StreamExecLocalGroupAggregate.java |  4 ++
 .../stream/StreamExecLocalWindowAggregate.java     |  1 +
 .../nodes/exec/stream/StreamExecOverAggregate.java |  1 +
 .../StreamExecPythonGroupWindowAggregate.java      |  2 +
 .../plan/nodes/exec/stream/StreamExecRank.java     |  1 +
 .../plan/nodes/exec/stream/StreamExecSink.java     |  7 +++
 .../plan/nodes/exec/stream/StreamExecSort.java     | 16 ++-----
 .../nodes/exec/stream/StreamExecSortLimit.java     |  1 +
 .../nodes/exec/stream/StreamExecTemporalJoin.java  |  1 +
 .../exec/stream/StreamExecWatermarkAssigner.java   |  1 +
 .../exec/stream/StreamExecWindowAggregate.java     |  1 +
 .../exec/stream/StreamExecWindowDeduplicate.java   |  1 +
 .../nodes/exec/stream/StreamExecWindowJoin.java    |  1 +
 .../nodes/exec/stream/StreamExecWindowRank.java    |  1 +
 .../exec/stream/StreamExecWindowTableFunction.java |  1 +
 .../plan/nodes/exec/utils/CommonPythonUtil.java    |  2 +-
 .../table/planner/utils/InternalConfigOptions.java | 13 ++++++
 .../nodes/exec/operator/OperatorNameTestBase.java  |  4 +-
 .../runtime/stream/sql/DeduplicateITCase.scala     |  7 +--
 .../planner/runtime/stream/sql/SortITCase.scala    | 13 +++---
 36 files changed, 183 insertions(+), 96 deletions(-)
 delete mode 100644 flink-architecture-tests/flink-architecture-tests-production/archunit-violations/52c5c6a1-204f-462d-9efa-4ffcb100fb4d