This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 78cd462 [FLINK-19750][connector/kafka] Fix bug of not opening
DeserializationSchema when FlinkKafkaConsumerBase recovers from state (#13785)
add 3dd5762 [FLINK-19154] ApplicationDispatcherBootstrap cleans up HA
data only on FAILED, CANCELLED, SUCCEEDED
add 2ff910f [FLINK-19154] Pass DispatcherGateway to DispatcherBootstrap
add 69db02b [hotfix] Merge ApplicationDispatcherBootstrap#initialize()
with constructor.
add 61a9f25 [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 | 18 +-
.../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, 408 insertions(+), 319 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-clients/src/main/java/org/apache/flink/client/program/ClusterClientProvider.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%)
