Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r170249880 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskExecutorLocalStateStoresManager.java --- @@ -186,6 +210,34 @@ private void doRelease(Iterable<TaskLocalStateStore> toRelease) { return localRecoveryMode; } + private File[] allocationBaseDirectories(AllocationID allocationID) { + File[] allocationDirectories = new File[localStateRootDirectories.length]; + for (int i = 0; i < localStateRootDirectories.length; ++i) { + allocationDirectories[i] = new File(localStateRootDirectories[i], allocationSubDirString(allocationID)); --- End diff -- `allocationSubDirString` could be pulled out of the loop.
---