This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8fc657b8 [FLINK-25669][runtime] Support register operator coordinators
for newly initialized ExecutionJobVertex
add 0b8a129 [hotfix][docs] Regenerate config docs
add 08f86a0 [FLINK-25715][runtime] Introduce
TestingDispatcherGateway#newBuilder() method
add 4255652 [FLINK-25715][coordination] Allow submission of failed jobs
No new revisions were added by this update.
Summary of changes:
.../generated/all_taskmanager_network_section.html | 12 +-
.../generated/deployment_configuration.html | 6 +
.../ApplicationDispatcherBootstrap.java | 44 ++++++--
.../ApplicationDispatcherBootstrapITCase.java | 71 ++++++++++--
.../ApplicationDispatcherBootstrapTest.java | 123 +++++++++++++++++++--
.../RestClusterClientSavepointTriggerTest.java | 2 +-
.../client/program/rest/RestClusterClientTest.java | 2 +-
.../apache/flink/client/testjar/BlockingJob.java | 2 +-
.../{MultiExecuteJob.java => FailingJob.java} | 39 ++-----
.../flink/configuration/DeploymentOptions.java | 20 ++++
.../webmonitor/WebSubmissionExtensionTest.java | 2 +-
.../handlers/JarHandlerParameterTest.java | 2 +-
.../webmonitor/handlers/JarHandlerTest.java | 2 +-
.../webmonitor/handlers/JarSubmissionITCase.java | 2 +-
.../flink/runtime/dispatcher/Dispatcher.java | 15 +++
.../runtime/dispatcher/DispatcherGateway.java | 3 +
.../flink/runtime/dispatcher/DispatcherTest.java | 41 ++++++-
.../runner/DefaultDispatcherRunnerTest.java | 2 +-
.../runner/SessionDispatcherLeaderProcessTest.java | 8 +-
.../runner/TestingDispatcherGatewayService.java | 3 +-
.../rest/handler/AbstractHandlerITCase.java | 2 +-
.../cluster/JobManagerCustomLogHandlerTest.java | 2 +-
.../cluster/JobManagerLogListHandlerTest.java | 2 +-
.../rest/handler/job/JobSubmitHandlerTest.java | 10 +-
.../webmonitor/TestingDispatcherGateway.java | 34 ++++++
25 files changed, 358 insertions(+), 93 deletions(-)
copy
flink-clients/src/test/java/org/apache/flink/client/testjar/{MultiExecuteJob.java
=> FailingJob.java} (59%)
