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 43528be1b10 [FLINK-32000][webui] Expose max parallelism in the vertex
detail drawer.
new 43688339721 [hotfix][test] Adds utility methods to OneShotLatch
new 1d208f13d89 [hotfix][test] Adds helper method to
testingLeaderElectionDriver for specifying session ID
new ed195cfedbb [hotfix][test] Adds generic testing implementations for
LeaderContender and LeaderElectionDriver
new b814c369256 [FLINK-31878][runtime] Adds event processing in a separate
thread to DefaultLeaderElectionService
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../DefaultLeaderElectionService.java | 62 ++++-
.../leaderelection/LeaderElectionEventHandler.java | 6 +
.../DefaultLeaderElectionServiceTest.java | 280 ++++++++++++++++++---
.../TestingGenericLeaderContender.java | 116 +++++++++
.../TestingGenericLeaderElectionDriver.java | 94 +++++++
.../TestingLeaderElectionDriver.java | 8 +-
.../apache/flink/core/testutils/OneShotLatch.java | 24 ++
7 files changed, 543 insertions(+), 47 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/TestingGenericLeaderContender.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/TestingGenericLeaderElectionDriver.java
