This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8dd2a3d [hotfix][Runtime/Coordination] Minor fix
add 2770ace [FLINK-25431][runtime] Implement a file-based JobResultStore
No new revisions were added by this update.
Summary of changes:
docs/content/docs/deployment/config.md | 4 +
.../common_high_availability_jrs_section.html | 24 +++
.../generated/job_result_store_configuration.html | 24 +++
.../flink/annotation/docs/Documentation.java | 2 +
.../configuration/ConfigOptionsDocGenerator.java | 2 +
.../highavailability/KubernetesHaServices.java | 12 +-
...sMultipleComponentLeaderElectionHaServices.java | 14 +-
.../AbstractThreadsafeJobResultStore.java | 123 ++++++++++++
.../highavailability/FileSystemJobResultStore.java | 215 +++++++++++++++++++++
.../highavailability/JobResultStoreOptions.java | 68 +++++++
.../nonha/embedded/EmbeddedJobResultStore.java | 104 +++-------
.../zookeeper/AbstractZooKeeperHaServices.java | 12 +-
.../zookeeper/ZooKeeperHaServices.java | 4 +-
.../FileSystemJobResultStoreContractTest.java | 40 ++++
.../FileSystemJobResultStoreTestInternal.java | 194 +++++++++++++++++++
.../JobResultStoreContractTest.java | 152 +++++++++++++++
.../EmbeddedJobResultStoreContractTest.java | 35 ++++
.../nonha/embedded/EmbeddedJobResultStoreTest.java | 204 -------------------
18 files changed, 938 insertions(+), 295 deletions(-)
create mode 100644
docs/layouts/shortcodes/generated/common_high_availability_jrs_section.html
create mode 100644
docs/layouts/shortcodes/generated/job_result_store_configuration.html
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/AbstractThreadsafeJobResultStore.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStore.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/JobResultStoreOptions.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStoreContractTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/FileSystemJobResultStoreTestInternal.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/JobResultStoreContractTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedJobResultStoreContractTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedJobResultStoreTest.java
