fapaul commented on a change in pull request #18043:
URL: https://github.com/apache/flink/pull/18043#discussion_r766666624
##########
File path:
flink-clients/src/main/java/org/apache/flink/client/program/StreamContextEnvironment.java
##########
@@ -93,6 +137,23 @@ public JobExecutionResult execute(StreamGraph streamGraph)
throws Exception {
}
}
+ private void checkNotAllowedConfigurations(StreamGraph streamGraph)
+ throws FatalProgramInvocationException {
+ errorMessages.addAll(collectNotAllowedConfigurations());
+ if (!errorMessages.isEmpty()) {
+ // HACK: We shortcut the StreamGraph to jobgraph translation
because we already
+ // know that the job needs to fail and can derive the jobId.
Review comment:
Yes, you are right in the case of multiple executes we will only capture
the first one https://github.com/apache/flink/pull/17995#discussion_r762959216 .
I would see exception handling for multiple jobs out of scope for this PR
because therefore we probably have to rethink how the Application mode
interacts with the cluster components.
--
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]
