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 a5198b8 [FLINK-14334][es][docs] Use ExceptionUtils#findThrowable
add 11c2610 [hotfix] Remove Scala Promise from LeaderRetrievalUtils
add 7e7ee28 [FLINK-14287] Decouple leader address from LeaderContender
No new revisions were added by this update.
Summary of changes:
.../flink/runtime/dispatcher/Dispatcher.java | 2 +-
.../nonha/embedded/EmbeddedLeaderService.java | 17 ++++---
.../SingleLeaderElectionService.java | 7 ++-
.../runtime/jobmaster/JobManagerRunnerImpl.java | 13 +++--
.../leaderelection/LeaderElectionService.java | 20 ++++----
.../StandaloneLeaderElectionService.java | 2 +-
.../ZooKeeperLeaderElectionService.java | 59 +++++++++++++---------
.../runtime/resourcemanager/ResourceManager.java | 2 +-
.../flink/runtime/util/LeaderRetrievalUtils.java | 23 +++------
.../runtime/webmonitor/WebMonitorEndpoint.java | 2 +-
.../nonha/embedded/EmbeddedHaServicesTest.java | 8 +--
.../SingleLeaderElectionServiceTest.java | 2 +-
.../runtime/leaderelection/LeaderElectionTest.java | 2 +-
.../runtime/leaderelection/TestingContender.java | 2 +-
.../TestingLeaderElectionService.java | 2 +-
.../resourcemanager/ResourceManagerHATest.java | 2 +-
.../util/DocumentingDispatcherRestEndpoint.java | 2 +-
.../YarnIntraNonHaMasterServicesTest.java | 2 +-
18 files changed, 93 insertions(+), 76 deletions(-)
