[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

[StefanRRichter]

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

    https://github.com/apache/flink/pull/5239#discussion_r168168982
  
    --- Diff: 
flink-runtime/src/test/java/org/apache/flink/runtime/state/TestTaskStateManager.java
 ---
    @@ -67,8 +69,11 @@ public TestTaskStateManager(
                this.jobId = jobId;
                this.executionAttemptID = executionAttemptID;
                this.checkpointResponder = checkpointResponder;
    -           this.taskStateSnapshotsByCheckpointId = new HashMap<>();
    +           this.jobManagerTaskStateSnapshotsByCheckpointId = new 
HashMap<>();
    +           this.taskManagerTaskStateSnapshotsByCheckpointId = new 
HashMap<>();
                this.reportedCheckpointId = -1L;
    +           this.subtaskLocalStateBaseDirectory =
    +                   new File(System.getProperty("java.io.tmpdir"), 
"testLocalState_" + UUID.randomUUID());
    --- End diff --
    
    This is already changed in later commits.


---