[core] Sync deleteFiles in OrphanFilesClean

apache · Apr 8, 2024 · 78bc72d · 78bc72d
1 parent f3f7008
commit 78bc72d
Showing 1 changed file with 1 addition and 1 deletion.
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,7 +476,7 @@ private List<Path> filterAndCleanDataDirs(
                     .forEach(
                             p -> {
                                 deleteFileOrDirQuietly(p);
-                                synchronized (this) {
+                                synchronized (deleteFiles) {
                                     deleteFiles.add(p);
                                     deletedFilesNum++;
                                 }