This is an automated email from the ASF dual-hosted git repository. zakelly pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3e399312ddce892c21956e7616e0d10e59e6ea82 Author: Zakelly <[email protected]> AuthorDate: Mon Mar 10 02:46:12 2025 +0800 [FLINK-37437][state/forst] Store misc files in local for rescaling --- .../apache/flink/state/forst/fs/filemapping/FileMappingManager.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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 index 963645a10e0..a9709b06b1b 100644 --- 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 class FileMappingManager { } 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) {
