[flink-benchmarks] branch master updated: [FLINK-28241] Overridden REQUIREMENTS CHECK DELAY to zero to avoid delay on initial phase of each job start.

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

roman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-benchmarks.git


The following commit(s) were added to refs/heads/master by this push:
     new 5d2f5a9  [FLINK-28241] Overridden REQUIREMENTS CHECK DELAY to zero to avoid delay on initial phase of each job start.
5d2f5a9 is described below

commit 5d2f5a96b4bcb6f2e96db0a16a7ccea6280c91e2
Author: Anton Kalashnikov <ka...@yandex.ru>
AuthorDate: Fri Jun 24 12:39:09 2022 +0200

    [FLINK-28241] Overridden REQUIREMENTS CHECK DELAY to zero to avoid delay on initial phase of each job start.
---
 .../java/org/apache/flink/benchmark/FlinkEnvironmentContext.java     | 5 +++++
 1 file changed, 5 insertions(+)

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.Setup;
 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 @@ public class FlinkEnvironmentContext {
         // 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;
     }
 }