Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r168176949
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java
---
@@ -197,7 +201,13 @@ public static TaskManagerServices fromConfiguration(
final JobManagerTable jobManagerTable = new JobManagerTable();
final JobLeaderService jobLeaderService = new
JobLeaderService(taskManagerLocation);
- final TaskExecutorLocalStateStoresManager taskStateManager =
new TaskExecutorLocalStateStoresManager();
+
+ final File taskExecutorLocalStateRootDir =
+ new
File(taskManagerServicesConfiguration.getLocalStateRootDir(),
LOCAL_STATE_SUB_DIRECTORY_ROOT);
--- End diff --
No, they can share the same directories, because inside things are further
grouped into per-allocation directories.
---
