fapaul commented on a change in pull request #17995:
URL: https://github.com/apache/flink/pull/17995#discussion_r762959216
##########
File path:
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java
##########
@@ -282,6 +292,9 @@ private void runApplicationEntryPoint(
} else {
jobIdsFuture.complete(applicationJobIds);
}
+ } catch (JobStartupFailedException e) {
+ jobIdsFuture.completeExceptionally(e);
Review comment:
We will basically discard the first job and it will look as if only one
job was executed. It follows the principle described here [1].
We have to execute the complete user program with all its `execute`s to
derive the list of job ids. In case of a failure, the already collected job ids
are discarded.
[1]
https://github.com/apache/flink/blob/bd4b0aa2ace713ca81ab3aa1ffe3bd86822d365c/flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java#L220
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
