fix

IGinX-THU · Apr 18, 2024 · 2c02235 · 2c02235
1 parent 9a03840
commit 2c02235
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/...ces/filesystem/src/main/java/cn/edu/tsinghua/iginx/filesystem/exec/FileSystemManager.java b/...ces/filesystem/src/main/java/cn/edu/tsinghua/iginx/filesystem/exec/FileSystemManager.java
@@ -307,17 +307,16 @@ public void deleteFiles(List<File> files, TagFilter filter) throws IOException {
 
   public void trimFilesContent(List<File> files, TagFilter tagFilter, long startKey, long endKey)
       throws IOException {
-    files =
-        files.stream()
-            .map(f -> FilePathUtils.normalize(f, FileAccessType.WRITE))
-            .collect(Collectors.toList());
-
     for (File file : files) {
       List<File> fileList = getFilesWithTagFilter(file, tagFilter, false);
       if (fileList.isEmpty()) {
         LOGGER.warn("cant trim the file that not exist!");
         continue;
       }
+      fileList =
+          fileList.stream()
+              .map(f -> FilePathUtils.normalize(f, FileAccessType.WRITE))
+              .collect(Collectors.toList());
       for (File f : fileList) {
         fileOperator.trimFile(f, startKey, endKey);
       }