[HUDI-9009] Fix potential race condition when listing files by levera…

…ging exception type #12834
apache · Feb 13, 2025 · d1d2f7c · d1d2f7c
1 parent 7cea766
commit d1d2f7c
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java b/hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java
@@ -481,13 +481,9 @@ public static List<StoragePathInfo> getAllDataFilesInPartition(HoodieStorage sto
         String extension = FSUtils.getFileExtension(path.getName());
         return validFileExtensions.contains(extension) || path.getName().contains(logFileExtension);
       }).stream().filter(StoragePathInfo::isFile).collect(Collectors.toList());
-    } catch (IOException e) {
+    } catch (FileNotFoundException ex) {
       // return empty FileStatus if partition does not exist already
-      if (!storage.exists(partitionPath)) {
-        return Collections.emptyList();
-      } else {
-        throw e;
-      }
+      return Collections.emptyList();
     }
   }