This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from bfd42f9 [hotfix][docs] Remove unused variable
add f29a18e [FLINK-19154] ApplicationDispatcherBootstrap cleans up HA
data only on FAILED, CANCELLED, SUCCEEDED
add 021456d [FLINK-19154] Pass DispatcherGateway to DispatcherBootstrap
add c5ec0b0 [FLINK-19154] Merge
ApplicationDispatcherBootstrap#initialize() with constructor.
add f02b951 [hotfix] minor refactoring in ApplicationDispatcherBootstrap
No new revisions were added by this update.
Summary of changes:
.../ApplicationDispatcherBootstrap.java | 151 +++++++---------
...ApplicationDispatcherGatewayServiceFactory.java | 18 +-
.../application/ApplicationFailureException.java | 82 +++++++++
.../ApplicationDispatcherBootstrapTest.java | 198 ++++++++++++++-------
.../dispatcher/AbstractDispatcherBootstrap.java | 46 -----
.../dispatcher/DefaultDispatcherBootstrap.java | 53 ------
.../flink/runtime/dispatcher/Dispatcher.java | 28 ++-
.../runtime/dispatcher/DispatcherBootstrap.java | 13 +-
.../dispatcher/DispatcherBootstrapFactory.java | 21 ++-
.../runtime/dispatcher/DispatcherFactory.java | 12 +-
.../runtime/dispatcher/JobDispatcherFactory.java | 13 +-
.../flink/runtime/dispatcher/MiniDispatcher.java | 7 +-
.../dispatcher/NoOpDispatcherBootstrap.java | 17 +-
.../dispatcher/SessionDispatcherFactory.java | 9 +-
.../runtime/dispatcher/StandaloneDispatcher.java | 8 +-
.../DefaultDispatcherGatewayServiceFactory.java | 9 +-
.../dispatcher/DispatcherResourceCleanupTest.java | 3 +-
.../flink/runtime/dispatcher/DispatcherTest.java | 22 ++-
.../runtime/dispatcher/MiniDispatcherTest.java | 4 +-
.../runtime/dispatcher/TestingDispatcher.java | 8 +-
.../runner/DefaultDispatcherRunnerITCase.java | 8 +-
21 files changed, 409 insertions(+), 321 deletions(-)
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationFailureException.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/AbstractDispatcherBootstrap.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DefaultDispatcherBootstrap.java
copy
flink-annotations/src/main/java/org/apache/flink/annotation/docs/ConfigGroup.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherBootstrapFactory.java
(66%)
copy
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/DoubleFieldReader.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/NoOpDispatcherBootstrap.java
(69%)
