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