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 467a0d1 [FLINK-20616][python] Support row-based operation to accept
user-defined function directly
add 25edfa2 [hotfix] Let
TestingOnCompletionActions.getJobMasterFailedFuture return jobMasterFailedFuture
add b021419 [hotfix] Remove unused method
JobManagerRunnerImpl#isShutdown()
add fe2a5ce [hotfix][tests] Extend TestingSchedulerNG to accept a
triggerSavepoint function
add 5fc355e [FLINK-11719] Do not reuse JobMasterServices across leader
sessions
add a2b04fb [FLINK-11719] Make JobMaster a PermanentlyFencedRpcEndpoint
add 95d5bd5 [FLINK-11719] Make SchedulerNG in JobMaster final
add f102274 [FLINK-11719] Factor HeartbeatManager creation out into
separate methods
add bebdef7 [hotfix] Split final and non-final fields in JobMaster
add c7084b3 [FLINK-11719] Make starting and stopping of JobMaster
services symmetric
No new revisions were added by this update.
Summary of changes:
.../runtime/jobmaster/JobManagerRunnerImpl.java | 180 ++++----
.../apache/flink/runtime/jobmaster/JobMaster.java | 318 ++++++--------
.../flink/runtime/jobmaster/JobMasterService.java | 21 -
.../factories/DefaultJobMasterServiceFactory.java | 9 +-
.../factories/JobMasterServiceFactory.java | 2 +
.../flink/runtime/dispatcher/DispatcherTest.java | 2 +
.../jobmaster/JobManagerRunnerImplTest.java | 49 +--
...asterExecutionDeploymentReconciliationTest.java | 2 +-
.../jobmaster/JobMasterPartitionReleaseTest.java | 2 +-
.../runtime/jobmaster/JobMasterSchedulerTest.java | 36 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 461 ++++++---------------
.../runtime/jobmaster/TestingJobMasterService.java | 41 +-
.../factories/TestingJobMasterServiceFactory.java | 3 +-
.../runtime/jobmaster/utils/JobMasterBuilder.java | 13 +-
.../runtime/scheduler/TestingSchedulerNG.java | 20 +-
.../scheduler/TestingSchedulerNGFactory.java | 70 ++++
16 files changed, 482 insertions(+), 747 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TestingSchedulerNGFactory.java
