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
