commit 5d2f5a96b4bcb6f2e96db0a16a7ccea6280c91e2
author Anton Kalashnikov <kaa.dev@yandex.ru> Fri Jun 24 12:39:09 2022 +0200
committer Roman <khachatryan.roman@gmail.com> Mon Jun 27 08:16:12 2022 +0200
tree 1600507931e317b56ed792fc183c08c6db71dbb1
parent 989e4fae452ecdd3c749d9f4493c34e63e0c41c2

[FLINK-28241] Overridden REQUIREMENTS CHECK DELAY to zero to avoid delay on initial phase of each job start.

src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java

diff --git a/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java b/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
index 6f4cd62..1b09133 100644
--- a/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
+++ b/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
@@ -34,6 +34,9 @@
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.TearDown;
 
+import java.time.Duration;
+
+import static org.apache.flink.configuration.ResourceManagerOptions.REQUIREMENTS_CHECK_DELAY;
 import static org.openjdk.jmh.annotations.Scope.Thread;
 
 @State(Thread)
@@ -107,6 +110,8 @@
         // It doesn't make sense to wait for the final checkpoint in benchmarks since it only prolongs
         // the test but doesn't give any advantages.
         configuration.set(ExecutionCheckpointingOptions.ENABLE_CHECKPOINTS_AFTER_TASKS_FINISH, false);
+        // TODO: remove this line after FLINK-28243 will be done
+        configuration.set(REQUIREMENTS_CHECK_DELAY, Duration.ZERO);
         return configuration;
     }
 }