This is an automated email from the ASF dual-hosted git repository.
zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from d481fb32219 [hotfix][NOTICE] Update copyright NOTICE year to 2026
(#27380)
add fec9336e7d9 [FLINK-38762][runtime] Introduce SingleJobApplication
No new revisions were added by this update.
Summary of changes:
.../application/executors/EmbeddedExecutor.java | 12 +-
.../executors/WebSubmissionExecutor.java | 52 ++++
.../executors/WebSubmissionExecutorFactory.java | 4 +-
.../WebSubmissionExecutorServiceLoader.java | 2 +-
.../handlers/JarHandlerParameterTest.java | 18 +-
.../webmonitor/handlers/JarSubmissionITCase.java | 4 +-
.../runtime/application/AbstractApplication.java | 4 +-
.../runtime/application/SingleJobApplication.java | 174 +++++++++++
.../flink/runtime/dispatcher/Dispatcher.java | 128 ++++++--
.../runtime/dispatcher/DispatcherGateway.java | 11 +
.../dispatcher/JobManagerRunnerFactory.java | 2 +
.../JobMasterServiceLeadershipRunnerFactory.java | 3 +
.../apache/flink/runtime/jobgraph/JobGraph.java | 1 +
.../apache/flink/runtime/jobmaster/JobMaster.java | 2 +
.../factories/DefaultJobMasterServiceFactory.java | 5 +
.../runtime/rest/handler/job/JobSubmitHandler.java | 7 +-
.../flink/streaming/api/graph/ExecutionPlan.java | 7 +
.../flink/streaming/api/graph/StreamGraph.java | 1 +
.../application/SingleJobApplicationTest.java | 329 +++++++++++++++++++++
.../dispatcher/DispatcherResourceCleanupTest.java | 5 +
.../flink/runtime/dispatcher/DispatcherTest.java | 305 ++++++++++++++++++-
...ingJobMasterServiceLeadershipRunnerFactory.java | 2 +
.../runtime/jobmaster/utils/JobMasterBuilder.java | 1 +
.../rest/handler/job/JobSubmitHandlerTest.java | 24 +-
.../webmonitor/TestingDispatcherGateway.java | 25 ++
25 files changed, 1070 insertions(+), 58 deletions(-)
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/WebSubmissionExecutor.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/application/SingleJobApplication.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/application/SingleJobApplicationTest.java
