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 64c725f4a6e [FLINK-32837][JUnit5 Migration] Migrate the client and
clusterframework packages of flink-runtime module to junit5 (#23241)
add 52cbeb90f32 [FLINK-27204] Refract FileSystemJobResultStore to execute
I/O operations on the ioExecutor
add 82a99f51b1b [hotfix][runtime] Remove IOException in the methods of
EmbeddedJobResultStore
add c40869e2f29 [hotfix][runtime] Modify the trace log level to debug in
JobMasterServiceLeadershipRunner
add c9fcb0c74b1 [hotfix][runtime] Remove getLeaderElection in
JobMasterServiceLeadershipRunner
No new revisions were added by this update.
Summary of changes:
.../ApplicationDispatcherBootstrapITCase.java | 10 +-
.../apache/flink/util/concurrent/FutureUtils.java | 20 ++
.../KubernetesLeaderElectionHaServices.java | 2 +-
.../flink/runtime/dispatcher/Dispatcher.java | 203 ++++++++++++---------
.../AbstractThreadsafeJobResultStore.java | 77 +++++---
.../highavailability/FileSystemJobResultStore.java | 12 +-
.../runtime/highavailability/JobResultStore.java | 59 +++---
.../nonha/embedded/EmbeddedJobResultStore.java | 14 +-
.../ZooKeeperLeaderElectionHaServices.java | 2 +-
.../JobMasterServiceLeadershipRunner.java | 182 ++++++++++--------
...Exception.java => LeadershipLostException.java} | 12 +-
.../dispatcher/DispatcherCleanupITCase.java | 14 +-
.../dispatcher/DispatcherResourceCleanupTest.java | 29 ++-
.../flink/runtime/dispatcher/DispatcherTest.java | 6 +-
.../FileSystemJobResultStoreContractTest.java | 4 +-
...FileSystemJobResultStoreFileOperationsTest.java | 90 +++++++--
.../JobResultStoreContractTest.java | 84 ++++++---
.../JobMasterServiceLeadershipRunnerTest.java | 2 +-
.../runtime/testutils/TestingJobResultStore.java | 78 ++++----
19 files changed, 553 insertions(+), 347 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/{LeaderElectionException.java
=> LeadershipLostException.java} (74%)
