This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b61e01a [FLINK-21497][coordination] Only complete leader future with
valid leader
add 172fdfe [FLINK-21606] Add JobID to
JobMasterGateway.registerTaskExecutor
add 258f54d [hotfix] Remove Mocking from RegisteredRpcConnectionTest
add 969fda2 [FLINK-21606] Introduce RegistrationResponse.Rejection and
RegisteredRpcConnection.onRegistrationRejection
add db0a5f5 [FLINK-21606] Release job resources on TaskExecutor if the
JobMaster rejects connection attempts
add 2f094da [FLINK-21606] Fail hard if the ResourceManager rejects a
JobMaster registration
add 7edd724 [FLINK-21606] Fail TaskExecutor hard if the ResourceManager
rejects its registration.
No new revisions were added by this update.
Summary of changes:
...Success.java => JMTMRegistrationRejection.java} | 29 ++--
.../apache/flink/runtime/jobmaster/JobMaster.java | 39 ++++-
.../flink/runtime/jobmaster/JobMasterGateway.java | 3 +
.../registration/RegisteredRpcConnection.java | 46 +++--
.../RegistrationConnectionListener.java | 13 +-
.../runtime/registration/RegistrationResponse.java | 51 ++++--
.../runtime/registration/RetryingRegistration.java | 97 +++++++++--
.../runtime/resourcemanager/ResourceManager.java | 15 +-
.../taskexecutor/DefaultJobLeaderService.java | 113 ++++++++----
.../runtime/taskexecutor/JobLeaderListener.java | 11 ++
.../flink/runtime/taskexecutor/TaskExecutor.java | 81 +++++++--
.../TaskExecutorRegistrationRejection.java} | 26 ++-
.../TaskExecutorToResourceManagerConnection.java | 27 ++-
.../jobmaster/JobMasterPartitionReleaseTest.java | 7 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 48 +++++-
.../jobmaster/utils/TestingJobMasterGateway.java | 13 +-
.../utils/TestingJobMasterGatewayBuilder.java | 12 +-
.../DefaultTestRegistrationGateway.java | 94 ++++++++++
... => ManualResponseTestRegistrationGateway.java} | 6 +-
.../registration/RegisteredRpcConnectionTest.java | 108 +++++++++---
.../registration/RetryingRegistrationTest.java | 189 +++++++++++++++------
.../registration/TestRegistrationGateway.java | 66 +------
.../ResourceManagerJobMasterTest.java | 4 +-
.../ResourceManagerTaskExecutorTest.java | 2 +-
.../taskexecutor/DefaultJobLeaderServiceTest.java | 57 +++++++
.../TaskExecutorPartitionLifecycleTest.java | 2 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 97 ++++++++++-
...askExecutorToResourceManagerConnectionTest.java | 30 +++-
28 files changed, 1013 insertions(+), 273 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/{JMTMRegistrationSuccess.java
=> JMTMRegistrationRejection.java} (55%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{metrics/groups/ResourceManagerMetricGroup.java
=> taskexecutor/TaskExecutorRegistrationRejection.java} (56%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/registration/DefaultTestRegistrationGateway.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/registration/{TestRegistrationGateway.java
=> ManualResponseTestRegistrationGateway.java} (92%)
