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 257ba6e [FLINK-14251] Add FutureUtils#forward utility
add 470558a [FLINK-14252] Encapsulate Dispatcher services in
DispatcherServices
add 1df5a0f [FLINK-14259] Introduce JobManagerRunner interface
No new revisions were added by this update.
Summary of changes:
.../dispatcher/DefaultJobManagerRunnerFactory.java | 5 +-
.../flink/runtime/dispatcher/Dispatcher.java | 53 ++-
.../runtime/dispatcher/DispatcherFactory.java | 23 +-
.../runtime/dispatcher/DispatcherServices.java | 86 +++++
.../runtime/dispatcher/JobDispatcherFactory.java | 35 +-
.../flink/runtime/dispatcher/MiniDispatcher.java | 36 +-
.../dispatcher/PartialDispatcherServices.java | 141 +++++++
.../dispatcher/SessionDispatcherFactory.java | 35 +-
.../runtime/dispatcher/StandaloneDispatcher.java | 36 +-
...tDispatcherResourceManagerComponentFactory.java | 12 +-
.../flink/runtime/jobmaster/JobManagerRunner.java | 418 +--------------------
...anagerRunner.java => JobManagerRunnerImpl.java} | 24 +-
.../runtime/dispatcher/MiniDispatcherTest.java | 23 +-
.../runtime/dispatcher/TestingDispatcher.java | 25 +-
.../dispatcher/TestingJobManagerRunnerFactory.java | 5 +-
...nnerTest.java => JobManagerRunnerImplTest.java} | 18 +-
.../runtime/jobmaster/TestingJobManagerRunner.java | 76 ++++
.../SessionDispatcherWithUUIDFactory.java | 39 +-
18 files changed, 431 insertions(+), 659 deletions(-)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherServices.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/PartialDispatcherServices.java
copy
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/{JobManagerRunner.java
=> JobManagerRunnerImpl.java} (97%)
rename
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/{JobManagerRunnerTest.java
=> JobManagerRunnerImplTest.java} (93%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/TestingJobManagerRunner.java
