You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2021/05/18 09:06:28 UTC
[flink] branch release-1.13 updated (57bc204 -> 13bc663)
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 57bc204 [FLINK-20695][ha] Clean ha data for job if globally terminated
add a24b0d8 [FLINK-22494][kubernetes] Introduces PossibleInconsistentStateException
add 6ce9cc9 [FLINK-22494][ha] Refactors TestingLongStateHandleHelper to operate on references
add b5c49ef [FLINK-22494][ha] Introduces PossibleInconsistentState to StateHandleStore
add a6c13e7 [FLINK-22494][runtime] Refactors CheckpointsCleaner to handle also discardOnFailedStoring
add 13bc663 [FLINK-22494][runtime] Adds PossibleInconsistentStateException handling to CheckpointCoordinator
No new revisions were added by this update.
Summary of changes:
.../KubernetesStateHandleStore.java | 74 +++-
.../kubeclient/Fabric8FlinkKubeClient.java | 11 +-
.../kubernetes/kubeclient/FlinkKubeClient.java | 8 +-
.../flink/kubernetes/KubernetesClientTestBase.java | 35 +-
.../flink/kubernetes/MixedKubernetesServer.java | 6 +-
.../KubernetesStateHandleStoreITCase.java | 10 +-
.../KubernetesStateHandleStoreTest.java | 482 +++++++++++++--------
.../kubeclient/Fabric8FlinkKubeClientTest.java | 49 ++-
.../runtime/checkpoint/CheckpointCoordinator.java | 26 +-
.../runtime/checkpoint/CheckpointsCleaner.java | 46 +-
.../DefaultCompletedCheckpointStore.java | 4 +
.../PossibleInconsistentStateException.java} | 25 +-
.../runtime/persistence/StateHandleStore.java | 13 +-
.../flink/runtime/util/StateHandleStoreUtils.java | 76 ++++
.../zookeeper/ZooKeeperStateHandleStore.java | 150 ++++---
.../CheckpointCoordinatorFailureTest.java | 96 +++-
.../CheckpointCoordinatorTestingUtils.java | 6 +
.../persistence/TestingLongStateHandleHelper.java | 104 +++--
.../runtime/util/StateHandleStoreUtilsTest.java | 114 +++++
.../zookeeper/ZooKeeperStateHandleStoreTest.java | 416 +++++++++++++-----
20 files changed, 1320 insertions(+), 431 deletions(-)
copy flink-runtime/src/main/java/org/apache/flink/runtime/{leaderelection/LeaderElectionException.java => persistence/PossibleInconsistentStateException.java} (58%)
create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/util/StateHandleStoreUtils.java
create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/util/StateHandleStoreUtilsTest.java