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 10:43:18 UTC
[flink] branch release-1.12 updated (814fc65 -> 6b53f8b)

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

trohrmann pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 814fc65  [FLINK-20695][ha] Clean ha data for job if globally terminated
     add a53a1f3  [FLINK-22494][kubernetes] Introduces PossibleInconsistentStateException
     add 95bd043  [FLINK-22494][ha] Refactors TestingLongStateHandleHelper to operate on references
     add b81887e  [FLINK-22494][ha] Introduces PossibleInconsistentState to StateHandleStore
     add 5aec1bb9 [FLINK-22494][runtime] Refactors CheckpointsCleaner to handle also discardOnFailedStoring
     add 6b53f8b  [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          |  92 +++-
 .../CheckpointCoordinatorTestingUtils.java         |   6 +
 .../persistence/TestingLongStateHandleHelper.java  | 104 +++--
 .../runtime/util/StateHandleStoreUtilsTest.java    | 114 +++++
 .../zookeeper/ZooKeeperStateHandleStoreTest.java   | 416 +++++++++++++-----
 20 files changed, 1316 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