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 5f7e0dc [FLINK-19543][k8s] Implement KubernetesRunningJobsRegistry
based Kubernetes API
add 653bc10 [hotfix][test] Add TestingRetrievableStateStorageHelper which
is settable with exception
add 2e08e2e [hotfix][coordination] Introduce CompletedCheckpointStore
composition mechanism and migrate ZooKeeperCompletedCheckpointStore
add dc56273 [FLINK-19544][k8s] Implement CheckpointRecoveryFactory based
on Kubernetes API
No new revisions were added by this update.
Summary of changes:
.../KubernetesCheckpointIDCounter.java | 151 +++++++++++
.../KubernetesCheckpointRecoveryFactory.java | 88 ++++++
.../KubernetesCheckpointStoreUtil.java | 67 +++++
.../highavailability/KubernetesHaServices.java | 4 +-
.../apache/flink/kubernetes/utils/Constants.java | 3 +
.../flink/kubernetes/utils/KubernetesUtils.java | 41 +++
.../KubernetesCheckpointIDCounterTest.java | 137 ++++++++++
.../CheckpointStoreUtil.java} | 24 +-
...e.java => DefaultCompletedCheckpointStore.java} | 239 +++++++---------
.../checkpoint/ZooKeeperCheckpointStoreUtil.java | 69 +++++
.../apache/flink/runtime/util/ZooKeeperUtils.java | 20 +-
.../DefaultCompletedCheckpointStoreTest.java | 300 +++++++++++++++++++++
.../ZooKeeperCompletedCheckpointStoreITCase.java | 37 ++-
...oKeeperCompletedCheckpointStoreMockitoTest.java | 12 +-
.../ZooKeeperCompletedCheckpointStoreTest.java | 28 +-
.../TestingRetrievableStateStorageHelper.java | 89 ++++++
16 files changed, 1127 insertions(+), 182 deletions(-)
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesCheckpointIDCounter.java
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesCheckpointRecoveryFactory.java
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesCheckpointStoreUtil.java
create mode 100644
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesCheckpointIDCounterTest.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{jobmanager/JobGraphStoreUtil.java
=> checkpoint/CheckpointStoreUtil.java} (61%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/{ZooKeeperCompletedCheckpointStore.java
=> DefaultCompletedCheckpointStore.java} (58%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointStoreUtil.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/DefaultCompletedCheckpointStoreTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/persistence/TestingRetrievableStateStorageHelper.java
