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.