[FLINK-37437][state/forst] Store misc files in local for rescaling

Zakelly · Zakelly · commit 3e399312ddce · 2025-03-10T13:58:55.000+08:00
diff --git a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/filemapping/FileMappingManager.java b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs/filemapping/FileMappingManager.java
@@ -338,10 +338,7 @@ public void giveUpOwnership(Path path, StreamStateHandle stateHandle) {
     }
 
     private Path forceLocalPath(Path filePath) {
-        if (isParentDir(filePath.toString(), remoteBase)) {
-            return new Path(localBase, filePath.getName());
-        }
-        return filePath;
+        return new Path(localBase, filePath.getName());
     }
 
     private Path toUUIDPath(Path filePath) {

Original file line number	Diff line number	Diff line change
`@@ -338,10 +338,7 @@ public void giveUpOwnership(Path path, StreamStateHandle stateHandle) {`
`338`	`338`	`}`
`339`	`339`
`340`	`340`	`private Path forceLocalPath(Path filePath) {`
`341`		`- if (isParentDir(filePath.toString(), remoteBase)) {`
`342`		`- return new Path(localBase, filePath.getName());`
`343`		`- }`
`344`		`- return filePath;`
	`341`	`+ return new Path(localBase, filePath.getName());`
`345`	`342`	`}`
`346`	`343`
`347`	`344`	`private Path toUUIDPath(Path filePath) {`