This is an automated email from the ASF dual-hosted git repository. dmvk pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 843fe8fc7e8fabebb8f9cc2daca2cdde77f555cf Author: David Moravek <[email protected]> AuthorDate: Tue Jan 16 18:43:18 2024 +0100 fixup! [FLINK-33976] Populate `scalingInterval{Min,Max}` options from the JobMaster's configuration instead of a Job configuration. --- .../apache/flink/runtime/scheduler/adaptive/Executing.java | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java index 257883f8123..d620755f1f1 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java @@ -84,19 +84,6 @@ class Executing extends StateWithExecutionGraph implements ResourceListener { // Executing is recreated with each restart (when we rescale) // we consider the first execution of the pipeline as a rescale event this.lastRescale = lastRescale; - Preconditions.checkState( - !scalingIntervalMin.isNegative(), - "%s must be positive integer or 0", - JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MIN.key()); - if (scalingIntervalMax != null) { - Preconditions.checkState( - scalingIntervalMax.compareTo(scalingIntervalMin) > 0, - "%s(%d) must be greater than %s(%d)", - JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MAX.key(), - scalingIntervalMax, - JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MIN.key(), - scalingIntervalMin); - } deploy();
