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/06/30 15:31:53 UTC
[flink] branch master updated (d98a34be120 -> 798d83a0fb4)

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 d98a34be120 [FLINK-27031][runtime] Assign even empty old state to the task if the upstream has output states since the task should be prepared to filter these old incoming states from upstream
     add 93146a78810 Revert "[FLINK-26079][state/changelog] Disallow recovery from non-changelog checkpoints"
     add 798d83a0fb4 [FLINK-25872][state] Support restore from non-changelog checkpoint with changelog enabled in CLAIM mode

No new revisions were added by this update.

Summary of changes:
 docs/content.zh/docs/ops/state/state_backends.md   |   4 +-
 docs/content/docs/ops/state/state_backends.md      |   4 +-
 .../AbstractCompleteCheckpointStore.java           |   2 +-
 .../runtime/checkpoint/CheckpointsCleaner.java     |  93 +++++++++++++++---
 .../DefaultCompletedCheckpointStore.java           |  33 ++++---
 .../EmbeddedCompletedCheckpointStore.java          |  18 +++-
 .../runtime/checkpoint/OperatorSubtaskState.java   |   9 ++
 .../StandaloneCompletedCheckpointStore.java        |  24 ++++-
 .../flink/runtime/state/SharedStateRegistry.java   |   8 +-
 .../runtime/state/SharedStateRegistryImpl.java     |  68 ++++++++++++-
 .../changelog/ChangelogStateBackendHandle.java     |  51 ++++++++++
 .../CheckpointCoordinatorFailureTest.java          |   3 +
 .../runtime/checkpoint/CheckpointsCleanerTest.java |  71 ++++++++++++++
 .../checkpoint/CompletedCheckpointStoreTest.java   |   8 +-
 .../runtime/state/SharedStateRegistryTest.java     |  21 +++++
 .../changelog/AbstractChangelogStateBackend.java   |  40 +-------
 ...ogPeriodicMaterializationSwitchEnvTestBase.java |  12 +++
 ...dicMaterializationSwitchStateBackendITCase.java | 105 +++++++++++++++++++++
 .../LegacyStatefulJobSavepointMigrationITCase.java |   1 -
 .../StatefulJobWBroadcastStateMigrationITCase.java |   1 -
 .../TypeSerializerSnapshotMigrationITCase.java     |   1 -
 .../test/state/ChangelogCompatibilityITCase.java   |   5 +-
 .../restore/AbstractOperatorRestoreTestBase.java   |   1 -
 .../StatefulJobSavepointMigrationITCase.scala      |   1 -
 ...StatefulJobWBroadcastStateMigrationITCase.scala |   1 -
 25 files changed, 489 insertions(+), 96 deletions(-)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointsCleanerTest.java