[GitHub] flink pull request #5750: [FLINK-8973] [E2E] HA end-to-end test with StateMa...

[twalthr]

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

    https://github.com/apache/flink/pull/5750#discussion_r177356523
  
    --- Diff: 
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/StateMachineExample.java
 ---
    @@ -105,7 +131,7 @@ public static void main(String[] args) throws Exception 
{
                                .flatMap(new StateMachineMapper());
     
                // output the alerts to std-out
    -           alerts.print();
    +           alerts.writeAsText(outputFile, FileSystem.WriteMode.OVERWRITE);
    --- End diff --
    
    Do we really need to change this? `test_resume_savepoint.sh` does not 
change the example.


---