This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1846bed [FLINK-22656] Fix typos
add 73fcaa1 [hotfix][runtime] Fixes JavaDoc for
RetrievableStateStorageHelper
add 15eafd9 [hotfix][runtime] Cleans up unnecessary annotations
add 9d2e2d9 [FLINK-22494][kubernetes] Introduces
PossibleInconsistentStateException
add cc59ad5 [FLINK-22494][ha] Refactors TestingLongStateHandleHelper to
operate on references
add 417cf78 [FLINK-22494][ha] Introduces PossibleInconsistentState to
StateHandleStore
add e632591 [FLINK-22494][runtime] Refactors CheckpointsCleaner to handle
also discardOnFailedStoring
add fa0d1dc [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 +-
.../persistence/RetrievableStateStorageHelper.java | 7 +-
.../runtime/persistence/StateHandleStore.java | 13 +-
.../flink/runtime/util/StateHandleStoreUtils.java | 76 ++++
.../zookeeper/ZooKeeperStateHandleStore.java | 152 ++++---
.../CheckpointCoordinatorFailureTest.java | 96 +++-
.../CheckpointCoordinatorTestingUtils.java | 6 +
.../persistence/TestingLongStateHandleHelper.java | 104 +++--
.../runtime/util/StateHandleStoreUtilsTest.java | 114 +++++
.../zookeeper/ZooKeeperStateHandleStoreTest.java | 416 +++++++++++++-----
21 files changed, 1323 insertions(+), 437 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
