This is an automated email from the ASF dual-hosted git repository.
liyu pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 08d941d [FLINK-16822][sql-client] `table.xx` property set from CLI
should also be set into TableEnvironment's TableConfig
add 1e9d72d [FLINK-16576][state backends] Fix the problem of wrong
mapping between stateId and metaInfo in HeapRestoreOperation
add ac2be60 [FLINK-16576][state backends] Do not distribute
KeyGroupsStateHandle which contains empty KeyGroupRange
No new revisions were added by this update.
Summary of changes:
.../checkpoint/StateAssignmentOperation.java | 32 +---
.../flink/runtime/state/KeyGroupsStateHandle.java | 7 +-
.../flink/runtime/state/KeyedStateHandle.java | 6 +-
.../runtime/state/heap/HeapRestoreOperation.java | 8 +-
.../runtime/state/KeyGroupsStateHandleTest.java | 59 ++++++
.../flink/runtime/state/StateBackendTestBase.java | 209 ++++++++++++++-------
.../util/AbstractStreamOperatorTestHarness.java | 12 +-
7 files changed, 225 insertions(+), 108 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/state/KeyGroupsStateHandleTest.java
