This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 94f69ee [FLINK-21685][k8s] Use dedicated thread pool for Kubernetes
client IO operations
add 049a48f [FLINK-21751][coordination] JM passes job status when
disconnecting
add 3409e7f [FLINK-21942][coordination] Remove job from
JobLeaderIdService when disconnecting JobManager with globally terminal state
add 8c475b3 [FLINK-21942] Extract JobLeaderIdService interface to make
the ResourceManager better testable
add c25dc3f [FLINK-21942][tests] Introduce TestingJobLeaderIdService and
use it in ResourceManagerTest
No new revisions were added by this update.
Summary of changes:
.../apache/flink/runtime/jobmaster/JobMaster.java | 3 +-
...Service.java => DefaultJobLeaderIdService.java} | 52 +---
.../resourcemanager/JobLeaderIdActions.java | 2 +-
.../resourcemanager/JobLeaderIdService.java | 324 ++-------------------
.../runtime/resourcemanager/ResourceManager.java | 23 +-
.../resourcemanager/ResourceManagerGateway.java | 4 +-
.../ResourceManagerRuntimeServices.java | 2 +-
...est.java => DefaultJobLeaderIdServiceTest.java} | 43 ++-
.../ResourceManagerJobMasterTest.java | 2 +-
.../ResourceManagerPartitionLifecycleTest.java | 2 +-
.../ResourceManagerTaskExecutorTest.java | 2 +-
.../resourcemanager/ResourceManagerTest.java | 81 +++++-
.../resourcemanager/TestingJobLeaderIdService.java | 170 +++++++++++
.../utils/MockResourceManagerRuntimeServices.java | 3 +-
.../utils/TestingResourceManagerGateway.java | 12 +-
15 files changed, 351 insertions(+), 374 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/{JobLeaderIdService.java
=> DefaultJobLeaderIdService.java} (89%)
mode change 100755 => 100644
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java
rename
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/{JobLeaderIdServiceTest.java
=> DefaultJobLeaderIdServiceTest.java} (88%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/TestingJobLeaderIdService.java
