[core] Fix the race condition in OrphanFilesClean (#3165)

apache · Apr 8, 2024 · f3f7008 · f3f7008
1 parent 676c829
commit f3f7008
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java b/paimon-core/src/main/java/org/apache/paimon/operation/OrphanFilesClean.java
@@ -476,8 +476,10 @@ private List<Path> filterAndCleanDataDirs(
                     .forEach(
                             p -> {
                                 deleteFileOrDirQuietly(p);
-                                deleteFiles.add(p);
-                                deletedFilesNum++;
+                                synchronized (this) {
+                                    deleteFiles.add(p);
+                                    deletedFilesNum++;
+                                }
                             });
         }