This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 3e6471436eb [FLINK-41260][table] Improve error msg by rejecting ORDER
BY in ARRAY_AGG and JSON_ARRAYAGG during planning
new 4f7d11117a2 [FLINK-41256][runtime] Add moveToNextKey to KeyContext and
KeyedStateBackend
new 8d7da02879e [FLINK-41256][runtime] Use moveToNextKey on the keyed
input path of key-sorted inputs
new f91e6224b83 [FLINK-41256][runtime] Fail on operators changing the
current key out of order in BATCH execution
new f9abda3bbef [FLINK-41256][runtime] Don't set the current key in
KeyedSortPartitionOperator
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../operators/StateBootstrapWrapperOperator.java | 5 +
.../python/AbstractPythonFunctionOperator.java | 9 ++
.../ExternalPythonKeyedCoProcessOperator.java | 9 ++
.../ExternalPythonKeyedProcessOperator.java | 9 ++
.../AbstractPythonStreamAggregateOperator.java | 5 +
.../flink/runtime/state/KeyedStateBackend.java | 9 ++
.../api/operators/AbstractStreamOperator.java | 24 ++-
.../api/operators/AbstractStreamOperatorV2.java | 24 ++-
.../flink/streaming/api/operators/KeyContext.java | 9 ++
.../api/operators/StreamOperatorStateHandler.java | 16 ++
.../state/BatchExecutionKeyedStateBackend.java | 22 ++-
.../sortpartition/KeyedSortPartitionOperator.java | 13 +-
.../BatchExecutionInternalTimeServiceTest.java | 24 +--
...utionInternalTimeServiceWithAsyncStateTest.java | 24 +--
.../sorted/state/BatchExecutionKeyOrderTest.java | 108 ++++++++++++++
.../state/BatchExecutionStateBackendTest.java | 162 ++++++++++-----------
.../KeyedSortPartitionOperatorTest.java | 29 ++--
.../AbstractUdfStreamOperatorLifecycleTest.java | 1 +
.../over/BufferDataOverWindowOperatorTest.java | 2 +
.../over/NonBufferOverWindowOperatorTest.java | 2 +
.../benchmark/StateBackendBenchmarkUtilsTest.java | 2 +-
.../datastream/DataStreamBatchExecutionITCase.java | 129 ++++++++++++++++
.../KeyedPartitionWindowedStreamITCase.java | 22 +++
23 files changed, 530 insertions(+), 129 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/streaming/api/operators/sorted/state/BatchExecutionKeyOrderTest.java
