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 76763da [hotfix][table][docs] Add missing braces
add dd365de [hotfix] Remove unnecessary generics from
DispatcherResourceManagerComponent
add 936a317 [FLINK-14280] Introduce DispatcherRunner
add 01ad0f6 [FLINK-14281] Add DispatcherRunner#getShutDownFuture
add 870b564 [FLINK-14282] Simplify DispatcherResourceManagerComponent
hierarchy
add 1c5f755 [FLINK-14284] Add shut down future to Dispatcher
add 282dd84 [FLINK-14285] Remove generics from Dispatcher factories
add 1082c7a [FLINK-14286] Remove Akka specific parsing from
LeaderConnectionInfo
No new revisions were added by this update.
Summary of changes:
.../entrypoint/StandaloneJobClusterEntryPoint.java | 6 +-
.../entrypoint/MesosJobClusterEntrypoint.java | 7 +--
.../entrypoint/MesosSessionClusterEntrypoint.java | 7 +--
.../flink/runtime/dispatcher/Dispatcher.java | 15 ++++-
.../runtime/dispatcher/DispatcherFactory.java | 6 +-
.../runtime/dispatcher/JobDispatcherFactory.java | 2 +-
.../flink/runtime/dispatcher/MiniDispatcher.java | 13 +---
.../dispatcher/SessionDispatcherFactory.java | 10 ++--
.../dispatcher/runner/DispatcherRunner.java | 33 ++++++----
.../runner/DispatcherRunnerFactory.java} | 14 ++---
.../runner/DispatcherRunnerFactoryImpl.java} | 33 +++++-----
.../dispatcher/runner/DispatcherRunnerImpl.java} | 49 +++++++++------
.../runtime/entrypoint/ClusterEntrypoint.java | 6 +-
.../StandaloneSessionClusterEntrypoint.java | 7 +--
...DispatcherResourceManagerComponentFactory.java} | 70 ++++++++++++----------
.../DispatcherResourceManagerComponent.java | 35 +++--------
.../DispatcherResourceManagerComponentFactory.java | 5 +-
.../JobDispatcherResourceManagerComponent.java | 53 ----------------
...bDispatcherResourceManagerComponentFactory.java | 55 -----------------
.../SessionDispatcherResourceManagerComponent.java | 38 ------------
...nDispatcherResourceManagerComponentFactory.java | 64 --------------------
.../flink/runtime/minicluster/MiniCluster.java | 17 +++---
.../flink/runtime/util/LeaderConnectionInfo.java | 56 +++--------------
.../flink/runtime/util/LeaderRetrievalUtils.java | 10 +---
.../flink/runtime/dispatcher/DispatcherTest.java | 4 +-
.../runtime/dispatcher/MiniDispatcherTest.java | 2 +-
.../dispatcher/ZooKeeperHADispatcherTest.java | 2 +-
...DispatcherResourceManagerComponentFactory.java} | 31 +++++-----
.../LeaderChangeClusterComponentsTest.java | 2 +-
.../SessionDispatcherWithUUIDFactory.java | 5 +-
.../runtime/minicluster/TestingMiniCluster.java | 18 +++---
.../recovery/ProcessFailureCancelingITCase.java | 9 +--
.../ZooKeeperLeaderElectionITCase.java | 33 ++++++----
.../yarn/entrypoint/YarnJobClusterEntrypoint.java | 7 +--
.../entrypoint/YarnSessionClusterEntrypoint.java | 6 +-
35 files changed, 247 insertions(+), 483 deletions(-)
copy
flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/HierarchyDescriptor.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/DispatcherRunner.java
(50%)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/{client/DuplicateJobSubmissionException.java
=> dispatcher/runner/DispatcherRunnerFactory.java} (67%)
copy
flink-runtime/src/{test/java/org/apache/flink/runtime/minicluster/SessionDispatcherWithUUIDFactory.java
=>
main/java/org/apache/flink/runtime/dispatcher/runner/DispatcherRunnerFactoryImpl.java}
(52%)
copy
flink-runtime/src/{test/java/org/apache/flink/runtime/minicluster/SessionDispatcherWithUUIDFactory.java
=>
main/java/org/apache/flink/runtime/dispatcher/runner/DispatcherRunnerImpl.java}
(52%)
rename
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/{AbstractDispatcherResourceManagerComponentFactory.java
=> DefaultDispatcherResourceManagerComponentFactory.java} (81%)
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/JobDispatcherResourceManagerComponent.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/JobDispatcherResourceManagerComponentFactory.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/SessionDispatcherResourceManagerComponent.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/SessionDispatcherResourceManagerComponentFactory.java
copy
flink-runtime/src/{main/java/org/apache/flink/runtime/jobmaster/JMTMRegistrationSuccess.java
=>
test/java/org/apache/flink/runtime/entrypoint/component/TestingDefaultDispatcherResourceManagerComponentFactory.java}
(50%)
