Github user tillrohrmann commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6283#discussion_r202070710
  
    --- Diff: 
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CoordinatorShutdownTest.java
 ---
    @@ -83,6 +86,10 @@ public void testCoordinatorShutsDownOnFailure() {
                                                
CheckpointRetentionPolicy.NEVER_RETAIN_AFTER_TERMINATION,
                                                true),
                                        null));
    +
    +                   ExecutionConfig executionConfig = new ExecutionConfig();
    +                   
executionConfig.setRestartStrategy(RestartStrategies.fallBackRestart());
    --- End diff --
    
    Should we maybe set the `FallbackRestartStrategyConfiguration` per default 
in the `ExecutionConfig`? That way, we could also simplify the resolve code.


---

Reply via email to