Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6283#discussion_r202297327
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java
---
@@ -149,7 +149,7 @@ public static RestartStrategyFactory
createRestartStrategyFactory(Configuration
}
// fallback in case of an error
- return
NoRestartStrategy.createFactory(configuration);
+ return
NoOrFixedIfCheckpointingEnabledRestartStrategy.createFactory(configuration);
--- End diff --
I think we should also create this factory if the `restart-strategy`
configuration value is `"non"` which is the default value.
---
