Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5031#discussion_r151920171
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/FixedDelayRestartStrategy.java
---
@@ -81,28 +80,19 @@ public void run() {
public static FixedDelayRestartStrategyFactory
createFactory(Configuration configuration) throws Exception {
int maxAttempts =
configuration.getInteger(ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS,
1);
- String timeoutString = configuration.getString(
- AkkaOptions.WATCH_HEARTBEAT_INTERVAL);
-
String delayString = configuration.getString(
ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_DELAY,
- timeoutString
+ "1 s"
--- End diff --
What about introducing a `ConfigOption`?
---
