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));
}
}