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 ca58a70 [FLINK-24703][connectors][format] Add CSV File System
encoding format based on BulkWriter.
add 8d5a4dd [hotfix] Adds fail to DispatcherTest
add bdb3657 [hotfix] Adds missing JavaDoc
add 3814867 [hotfix] Makes intention of comment clearer
add cfeaff1 [hotfix] Migrates ApplicationStatusTest to JUnit5 and AssertJ
add bf1a310 [hotfix] Adds TestLogger extension to
ApplicationDispatcherBootstrapTest
add 46952ef [hotfix] Introduces TestingPartialDispatcherServices
add 8d235d8 [hotfix] Removes @Nonnull annotations from DispatcherServices
and PartialDispatcherServicesWithJobGraphStore
add 5c39a7e [FLINK-25430][runtime] Add JobResultStore
add 01b14fc [FLINK-25430][runtime] Integrates JobResultStoreinto the
Dispatcher
add adbe872 [FLINK-25430][runtime] Renames JobGraphStoreFactory into
JobPersistenceComponentFactory
add 6c5ae20 [FLINK-25430][runtime] Renames
PartialDispatcherServicesWithJobGraphStore into
PartialDispatcherServicesWithJobPersistenceComponents
add 31d9caa [FLINK-25430][runtime] Integrates JobResultStore
initialization along JobGraphStore initialization
add 8c54900 [hotfix] Migrates SessionDispatcherLeaderProcessTest to
JUnit5/AssertJ
add 68948ae [hotfix] Migrates ApplicationDispatcherBootstrapITCase to
JUnit5/AssertJ
No new revisions were added by this update.
Summary of changes:
...ApplicationDispatcherGatewayServiceFactory.java | 13 +-
...ationDispatcherLeaderProcessFactoryFactory.java | 9 +-
.../ApplicationDispatcherBootstrapITCase.java | 86 ++++-
.../ApplicationDispatcherBootstrapTest.java | 10 +-
.../client/testjar/ErrorHandlingSubmissionJob.java | 75 ++++
.../java/org/apache/flink/util/CollectionUtil.java | 5 +
.../org/apache/flink/util/CollectionUtilTest.java | 29 +-
.../highavailability/KubernetesHaServices.java | 10 +-
...sMultipleComponentLeaderElectionHaServices.java | 9 +-
.../KubernetesRunningJobsRegistry.java | 157 --------
.../apache/flink/kubernetes/utils/Constants.java | 1 -
.../KubernetesRunningJobsRegistryTest.java | 123 -------
.../org/apache/flink/runtime/blob/BlobServer.java | 3 +-
.../clusterframework/ApplicationStatus.java | 2 +-
.../flink/runtime/dispatcher/Dispatcher.java | 83 ++++-
.../runtime/dispatcher/DispatcherFactory.java | 5 +-
.../runtime/dispatcher/DispatcherServices.java | 146 ++++----
.../runtime/dispatcher/JobDispatcherFactory.java | 21 +-
.../JobMasterServiceLeadershipRunnerFactory.java | 8 +-
.../flink/runtime/dispatcher/MiniDispatcher.java | 10 +-
...tcherServicesWithJobPersistenceComponents.java} | 52 +--
.../dispatcher/SessionDispatcherFactory.java | 8 +-
.../runtime/dispatcher/StandaloneDispatcher.java | 3 +
.../runner/AbstractDispatcherLeaderProcess.java | 26 +-
.../DefaultDispatcherGatewayServiceFactory.java | 13 +-
.../runner/DefaultDispatcherRunnerFactory.java | 6 +-
.../DispatcherLeaderProcessFactoryFactory.java | 4 +-
.../dispatcher/runner/DispatcherRunnerFactory.java | 4 +-
.../runner/JobDispatcherLeaderProcess.java | 26 +-
.../runner/JobDispatcherLeaderProcessFactory.java | 34 +-
.../JobDispatcherLeaderProcessFactoryFactory.java | 79 +++-
.../runner/SessionDispatcherLeaderProcess.java | 80 +++-
.../SessionDispatcherLeaderProcessFactory.java | 11 +-
...ssionDispatcherLeaderProcessFactoryFactory.java | 6 +-
...tDispatcherResourceManagerComponentFactory.java | 4 +-
.../highavailability/AbstractHaServices.java | 27 +-
.../highavailability/HighAvailabilityServices.java | 7 +-
.../JobResultEntry.java} | 35 +-
.../runtime/highavailability/JobResultStore.java | 111 ++++++
.../highavailability/RunningJobsRegistry.java | 92 -----
.../nonha/AbstractNonHaServices.java | 12 +-
.../nonha/embedded/EmbeddedJobResultStore.java | 131 +++++++
.../standalone/StandaloneRunningJobsRegistry.java | 70 ----
.../zookeeper/AbstractZooKeeperHaServices.java | 10 +-
.../zookeeper/ZooKeeperRunningJobsRegistry.java | 153 --------
... HaServicesJobPersistenceComponentFactory.java} | 26 +-
...ry.java => JobPersistenceComponentFactory.java} | 17 +-
.../JobMasterServiceLeadershipRunner.java | 59 +--
.../clusterframework/ApplicationStatusTest.java | 20 +-
.../runtime/dispatcher/AbstractDispatcherTest.java | 28 +-
.../dispatcher/DispatcherFailoverITCase.java | 8 +-
.../dispatcher/DispatcherResourceCleanupTest.java | 165 +++++++--
.../flink/runtime/dispatcher/DispatcherTest.java | 95 ++---
.../runtime/dispatcher/MiniDispatcherTest.java | 49 ++-
.../runtime/dispatcher/TestingDispatcher.java | 13 +-
.../dispatcher/TestingJobManagerRunnerFactory.java | 4 +
.../TestingPartialDispatcherServices.java | 184 ++++++++++
.../runner/DefaultDispatcherRunnerITCase.java | 44 +--
...bDispatcherLeaderProcessFactoryFactoryTest.java | 134 +++++++
.../runner/SessionDispatcherLeaderProcessTest.java | 405 +++++++++++++--------
.../runner/TestingDispatcherServiceFactory.java | 86 -----
.../ZooKeeperDefaultDispatcherRunnerTest.java | 23 +-
.../runtime/entrypoint/ClusterEntrypointTest.java | 4 +-
.../highavailability/AbstractHaServicesTest.java | 18 +-
.../TestingHighAvailabilityServices.java | 12 +-
.../TestingHighAvailabilityServicesBuilder.java | 11 +-
.../TestingManualHighAvailabilityServices.java | 6 +-
.../nonha/embedded/EmbeddedJobResultStoreTest.java | 204 +++++++++++
.../zookeeper/ZooKeeperHaServicesTest.java | 7 -
.../zookeeper/ZooKeeperRegistryTest.java | 97 -----
.../TestingJobPersistenceComponentFactory.java | 48 +++
.../JobMasterServiceLeadershipRunnerTest.java | 21 +-
.../runtime/testutils/TestingJobGraphStore.java | 1 +
.../runtime/testutils/TestingJobResultStore.java | 184 ++++++++++
74 files changed, 2342 insertions(+), 1440 deletions(-)
create mode 100644
flink-clients/src/test/java/org/apache/flink/client/testjar/ErrorHandlingSubmissionJob.java
delete mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/highavailability/KubernetesRunningJobsRegistry.java
delete mode 100644
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesRunningJobsRegistryTest.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/{PartialDispatcherServicesWithJobGraphStore.java
=> PartialDispatcherServicesWithJobPersistenceComponents.java} (67%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{dispatcher/DispatcherFactory.java
=> highavailability/JobResultEntry.java} (53%)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/JobResultStore.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/RunningJobsRegistry.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedJobResultStore.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/standalone/StandaloneRunningJobsRegistry.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRunningJobsRegistry.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/{HaServicesJobGraphStoreFactory.java
=> HaServicesJobPersistenceComponentFactory.java} (59%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/{JobGraphStoreFactory.java
=> JobPersistenceComponentFactory.java} (66%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/TestingPartialDispatcherServices.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/JobDispatcherLeaderProcessFactoryFactoryTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/runner/TestingDispatcherServiceFactory.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedJobResultStoreTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperRegistryTest.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/TestingJobPersistenceComponentFactory.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/testutils/TestingJobResultStore.java
