eemario commented on code in PR #27765:
URL: https://github.com/apache/flink/pull/27765#discussion_r2992269437
##########
flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationJobUtils.java:
##########
@@ -125,10 +127,24 @@ private static String checkClusterId(String str) {
return str;
}
- public static boolean allowExecuteMultipleJobs(Configuration config) {
- final Optional<String> configuredJobId =
-
config.getOptional(PipelineOptionsInternal.PIPELINE_FIXED_JOB_ID);
- return !HighAvailabilityMode.isHighAvailabilityModeActivated(config)
- && configuredJobId.isEmpty();
+ /**
+ * Returns the job count limits for the given configuration.
+ *
+ * @param config The configuration to get the job count limits from
+ * @return A tuple of (total job count limit, streaming job count limit)
+ */
+ public static Tuple2<Integer, Integer> getJobCountLimits(Configuration
config) {
+ if
(config.get(DeploymentOptions.SUBMIT_FAILED_JOB_ON_APPLICATION_ERROR)) {
+ // enforce single job execution
Review Comment:
Added explanation for the decision.
--
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]
