From 78bc72de2cc136e2047ccaae59e41856d958bb7d Mon Sep 17 00:00:00 2001 From: Jingsong Date: Mon, 8 Apr 2024 10:30:56 +0800 Subject: [PATCH] [core] Sync deleteFiles in OrphanFilesClean --- .../main/java/org/apache/paimon/operation/OrphanFilesClean.java | 2 +- 1 file changed, 1 insertion(+), 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 index f6ffd102c0ae..e78174db7ac9 100644 --- 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 filterAndCleanDataDirs( .forEach( p -> { deleteFileOrDirQuietly(p); - synchronized (this) { + synchronized (deleteFiles) { deleteFiles.add(p); deletedFilesNum++; }