[flink] branch master updated (76763da -> 1082c7a)

[tr...@apache.org]

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%)