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

    https://github.com/apache/flink/pull/5239#discussion_r168176031
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskStateManager.java
 ---
    @@ -60,4 +62,9 @@ void reportTaskStateSnapshots(
         * @return previous state for the operator. Null if no previous state 
exists.
         */
        OperatorSubtaskState operatorStates(OperatorID operatorID);
    +
    +   /**
    +    * Returns the base directory for all file-based local state of the 
owning subtask.
    +    */
    +   File getSubtaskLocalStateBaseDirectory();
    --- End diff --
    
    This is the manager, not the state objects. So for local recovery that is 
not based on local files, the backend will just not care about directories and 
no invoke this method.


---

Reply via email to