This is an automated email from the ASF dual-hosted git repository.

JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 8171884d05 [core] Use computeIfAbsent for dvMaintainer cache (#8394)
8171884d05 is described below

commit 8171884d056ffaf10ceff566fdb3ba58b6961c40
Author: cxzl25 <[email protected]>
AuthorDate: Wed Jul 1 13:33:33 2026 +0800

    [core] Use computeIfAbsent for dvMaintainer cache (#8394)
---
 .../org/apache/paimon/append/AppendCompactCoordinator.java  | 13 ++++---------
 1 file changed, 4 insertions(+), 9 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java
 
b/paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java
index 70e5040e3b..8ca9664093 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/append/AppendCompactCoordinator.java
@@ -387,16 +387,11 @@ public class AppendCompactCoordinator {
         }
 
         private AppendDeleteFileMaintainer dvMaintainer(BinaryRow partition) {
-            AppendDeleteFileMaintainer maintainer = cache.get(partition);
-            if (maintainer == null) {
-                synchronized (this) {
-                    maintainer =
+            return cache.computeIfAbsent(
+                    partition,
+                    p ->
                             BaseAppendDeleteFileMaintainer.forUnawareAppend(
-                                    indexFileHandler, 
snapshotManager.latestSnapshot(), partition);
-                }
-                cache.put(partition, maintainer);
-            }
-            return maintainer;
+                                    indexFileHandler, 
snapshotManager.latestSnapshot(), p));
         }
     }
 

Reply via email to