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 2021/12/16 15:34:08 UTC
[flink] branch master updated (c707401 -> 54a2179)
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 c707401 [FLINK-21068][connectors/elasticsearch] Support 'connection.request-timeout','connection.timeout', 'socket.timeout' options for elasticsearch connector.
add 66b5e5a [hotfix][runtime] Extract SharedStateRegistry interface
add aab40b8 [FLINK-24611] Pass checkpoint ID to SharedStateRegistry
add 70bf7a0 [FLINK-24611] Register shared state on checkpoint ACK
add ce125b2 [FLINK-24611] Discard shared state on checkpoint subsumption
add d07adc5 [FLINK-24611] Discard shared state on job termination
add 830d86d [FLINK-24611] Don't re-upload unconfirmed RocksDB SST
add f06389d [FLINK-24611] Adjust shared state entry de-duplication
add 54a2179 [hotfix] Update DeactivatedCheckpointCompletedCheckpointStore javadoc
No new revisions were added by this update.
Summary of changes:
.../AbstractCompleteCheckpointStore.java | 21 ++
.../runtime/checkpoint/CheckpointCoordinator.java | 29 +-
.../runtime/checkpoint/CompletedCheckpoint.java | 2 +-
...ctivatedCheckpointCompletedCheckpointStore.java | 2 +-
.../DefaultCompletedCheckpointStore.java | 22 +-
.../EmbeddedCompletedCheckpointStore.java | 14 +-
.../flink/runtime/checkpoint/OperatorState.java | 4 +-
.../runtime/checkpoint/OperatorSubtaskState.java | 12 +-
.../StandaloneCompletedCheckpointStore.java | 30 +-
.../flink/runtime/checkpoint/SubtaskState.java | 6 +-
.../apache/flink/runtime/checkpoint/TaskState.java | 4 +-
.../runtime/checkpoint/TaskStateSnapshot.java | 4 +-
.../flink/runtime/state/CompositeStateHandle.java | 8 +-
.../runtime/state/DirectoryKeyedStateHandle.java | 2 +-
.../state/IncrementalRemoteKeyedStateHandle.java | 24 +-
.../flink/runtime/state/KeyGroupsStateHandle.java | 2 +-
.../flink/runtime/state/SharedStateRegistry.java | 302 ++-------------------
.../runtime/state/SharedStateRegistryImpl.java | 278 +++++++++++++++++++
.../changelog/ChangelogStateBackendHandle.java | 6 +-
.../changelog/ChangelogStateHandleStreamImpl.java | 19 +-
.../inmemory/InMemoryChangelogStateHandle.java | 2 +-
.../CheckpointCoordinatorRestoringTest.java | 5 +-
.../checkpoint/CheckpointCoordinatorTest.java | 179 +++++++++---
.../checkpoint/CompletedCheckpointStoreTest.java | 30 +-
.../checkpoint/CompletedCheckpointTest.java | 9 +-
.../DefaultCompletedCheckpointStoreTest.java | 72 ++++-
.../runtime/checkpoint/PendingCheckpointTest.java | 3 +-
.../StandaloneCompletedCheckpointStoreTest.java | 5 +-
.../runtime/checkpoint/StateHandleDummyUtil.java | 2 +-
.../ZooKeeperCompletedCheckpointStoreITCase.java | 15 +-
.../ZooKeeperCompletedCheckpointStoreTest.java | 5 +-
.../runtime/scheduler/SchedulerUtilsTest.java | 2 +-
.../IncrementalRemoteKeyedStateHandleTest.java | 86 ++----
.../runtime/state/SharedStateRegistryTest.java | 73 ++---
.../state/StateBackendMigrationTestBase.java | 14 +-
.../flink/runtime/state/StateBackendTestBase.java | 52 ++--
.../runtime/state/ttl/StateBackendTestContext.java | 5 +-
.../state/ttl/mock/MockKeyedStateBackend.java | 2 +-
.../changelog/ChangelogStateBackendTestUtils.java | 5 +-
.../snapshot/RocksIncrementalSnapshotStrategy.java | 136 +++++++---
.../state/EmbeddedRocksDBStateBackendTest.java | 27 +-
.../streaming/runtime/tasks/StreamTaskTest.java | 2 +-
42 files changed, 894 insertions(+), 628 deletions(-)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java