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.
---
