[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_r168177861
  
    --- Diff: 
flink-runtime/src/test/java/org/apache/flink/runtime/state/TaskStateManagerImplTest.java
 ---
    @@ -25,17 +25,24 @@
     import org.apache.flink.runtime.checkpoint.OperatorSubtaskState;
     import org.apache.flink.runtime.checkpoint.TaskStateSnapshot;
     import org.apache.flink.runtime.executiongraph.ExecutionAttemptID;
    +import org.apache.flink.runtime.jobgraph.JobVertexID;
     import org.apache.flink.runtime.jobgraph.OperatorID;
     import org.apache.flink.runtime.taskmanager.CheckpointResponder;
     import org.apache.flink.runtime.taskmanager.TestCheckpointResponder;
     
     import org.junit.Assert;
     import org.junit.Test;
    +import org.junit.rules.TemporaryFolder;
    +
    +import java.io.IOException;
     
     import static org.mockito.Mockito.mock;
     
     public class TaskStateManagerImplTest {
    --- End diff --
    
    👍 


---