You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ta...@apache.org on 2022/02/11 16:23:33 UTC
[flink] branch master updated (3adca15 -> a519ed1)

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

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


    from 3adca15  [FLINK-25990][table-api-java-bridge] Add ProviderContext for generating uids in DataStream/Transformation Scan/SinkProvider
     add ae16608  [hotfix][changelog] Let ChangelogStateHandleStreamImpl to serialize checkpointed size
     add a519ed1  [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

No new revisions were added by this update.

Summary of changes:
 .../metadata/MetadataV2V3SerializerBase.java       | 102 +++++++++++----
 .../runtime/state/DirectoryKeyedStateHandle.java   |   8 ++
 .../state/IncrementalRemoteKeyedStateHandle.java   |  71 ++++++++++-
 .../flink/runtime/state/KeyGroupsStateHandle.java  |  26 +++-
 .../flink/runtime/state/KeyedStateHandle.java      |  13 ++
 .../apache/flink/runtime/state/StateHandleID.java  |   6 +
 .../changelog/ChangelogStateBackendHandle.java     | 109 +++++++++++++---
 .../changelog/ChangelogStateHandleStreamImpl.java  |  36 +++++-
 .../inmemory/InMemoryChangelogStateHandle.java     |  30 ++++-
 .../runtime/checkpoint/StateHandleDummyUtil.java   |   8 ++
 .../checkpoint/metadata/CheckpointTestUtils.java   |   7 +-
 .../metadata/MetadataV3SerializerTest.java         |  42 ++++++
 .../flink/runtime/state/ChangelogTestUtils.java    | 141 +++++++++++++++++++++
 .../IncrementalRemoteKeyedStateHandleTest.java     |  12 ++
 .../runtime/state/KeyGroupsStateHandleTest.java    |   1 +
 .../runtime/state/SharedStateRegistryTest.java     |  74 +++++++++++
 .../state/ttl/mock/MockKeyedStateBackend.java      |   8 ++
 .../changelog/ChangelogKeyedStateBackend.java      |   5 +-
 .../state/changelog/ChangelogStateBackend.java     |   3 +-
 .../streaming/runtime/tasks/StreamTaskTest.java    |   8 ++
 20 files changed, 650 insertions(+), 60 deletions(-)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/state/ChangelogTestUtils.java