commit 479f7f7c19507b72f03d777df5bf615720907068
author Piotr Nowojski <piotr.nowojski@gmail.com> Mon Aug 31 15:46:54 2020 +0200
committer Piotr Nowojski <pnowojski@users.noreply.github.com> Tue Sep 01 09:58:16 2020 +0200
tree 08c557d76fad604c7538cfd5b0d377579ebb890a
parent de049572690f4f744c9706dba5268e242f9e3bc8

[hotfix] Do not restart benchmarks in case of failures

This is in order to prevent faulty benchmarkes being restarted indefinetely
effectively dead/livelocking a benchmark.

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 c3d1b2c..c6bdbe8 100644
--- a/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
+++ b/src/main/java/org/apache/flink/benchmark/FlinkEnvironmentContext.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.benchmark;
 
+import org.apache.flink.api.common.restartstrategy.RestartStrategies;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.NettyShuffleEnvironmentOptions;
 import org.apache.flink.runtime.state.memory.MemoryStateBackend;
@@ -49,7 +50,7 @@
         if (objectReuse) {
             env.getConfig().enableObjectReuse();
         }
-
+        env.setRestartStrategy(RestartStrategies.noRestart());
         env.setStateBackend(new MemoryStateBackend());
     }