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 42a45a5 [FLINK-21709][table] Officially deprecate the legacy planner
add b24c5e6 [FLINK-21606] Add JobID to
JobMasterGateway.registerTaskExecutor
add 2de5ff00 [hotfix] Remove Mocking from RegisteredRpcConnectionTest
add 691f87e [FLINK-21606] Introduce RegistrationResponse.Rejection and
RegisteredRpcConnection.onRegistrationRejection
add 0bd837c [FLINK-21606] Release job resources on TaskExecutor if the
JobMaster rejects connection attempts
add 42b94df [FLINK-21606] Fail hard if the ResourceManager rejects a
JobMaster registration
add ab2f899 [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 ++-
...asterExecutionDeploymentReconciliationTest.java | 38 +++--
.../jobmaster/JobMasterPartitionReleaseTest.java | 9 +-
.../jobmaster/JobMasterQueryableStateTest.java | 17 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 53 +++++-
.../runtime/jobmaster/JobMasterTestUtils.java | 3 +
.../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 +-
.../active/ActiveResourceManagerTest.java | 2 +-
.../taskexecutor/DefaultJobLeaderServiceTest.java | 57 +++++++
...cutorExecutionDeploymentReconciliationTest.java | 2 +-
.../TaskExecutorPartitionLifecycleTest.java | 2 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 97 ++++++++++-
...askExecutorToResourceManagerConnectionTest.java | 30 +++-
33 files changed, 1057 insertions(+), 298 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%)
