You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ro...@apache.org on 2022/08/03 10:57:49 UTC
[flink] branch master updated (8c6a9e58f1e -> d8a4304b892)
This is an automated email from the ASF dual-hosted git repository.
roman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 8c6a9e58f1e [FLINK-28418][table] Add runtime provider interfaces for partial caching lookup (#20414)
add d8a4304b892 [FLINK-28597][state] Discard initial checkpoints without a delay in common cases
No new revisions were added by this update.
Summary of changes:
.../runtime/checkpoint/CheckpointProperties.java | 4 +-
.../flink/runtime/checkpoint/Checkpoints.java | 17 ++-
.../runtime/checkpoint/CompletedCheckpoint.java | 38 +++++-
.../runtime/checkpoint/PendingCheckpoint.java | 3 +-
.../checkpoint/metadata/CheckpointMetadata.java | 25 ++++
.../checkpoint/metadata/MetadataSerializer.java | 8 ++
.../checkpoint/metadata/MetadataSerializers.java | 3 +-
.../checkpoint/metadata/MetadataV1Serializer.java | 8 ++
.../checkpoint/metadata/MetadataV2Serializer.java | 7 +
.../checkpoint/metadata/MetadataV3Serializer.java | 3 +-
.../checkpoint/metadata/MetadataV4Serializer.java | 73 +++++++++++
.../flink/runtime/state/SharedStateRegistry.java | 16 ++-
.../runtime/state/SharedStateRegistryImpl.java | 62 ++++++++-
.../changelog/ChangelogStateBackendHandle.java | 3 +-
.../flink/runtime/checkpoint/CheckpointsTest.java | 61 +++++++++
.../metadata/MetadataV3SerializerTest.java | 2 +-
.../metadata/MetadataV4SerializerTest.java | 61 +++++++++
.../runtime/state/SharedStateRegistryTest.java | 144 +++++++++++++++++++--
18 files changed, 509 insertions(+), 29 deletions(-)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV4Serializer.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointsTest.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV4SerializerTest.java