apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CELEBORN-894][CELEBORN-474][FOLLOWUP] PushState uses JavaUtils#newConcurrentHashMap to speed up ConcurrentHashMap#computeIfAbsent

Browse Source 
### What changes were proposed in this pull request?

`PushState`  uses `JavaUtils#newConcurrentHashMap` to speed up `ConcurrentHashMap#computeIfAbsent`.

### Why are the changes needed?

Celeborn supports JDK8, which could meet the bug mentioned in [JDK-8161372](https://bugs.openjdk.org/browse/JDK-8161372). Therefore, it's better to use `JavaUtils#newConcurrentHashMap` to speed up `ConcurrentHashMap#computeIfAbsent`.

### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

CI.

Closes #3396 from SteNicholas/CELEBORN-894.

Authored-by: SteNicholas <programgeek@163.com>
Signed-off-by: SteNicholas <programgeek@163.com>
This commit is contained in:
SteNicholas 2025-07-29 10:30:31 +08:00
parent c6e68fddfa
commit 3ff44fae3f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
common/src/main/java/org/apache/celeborn/common/write/PushState.java
View File

@ -36,7 +36,7 @@ public class PushState {
private final InFlightRequestTracker inFlightRequestTracker;
// partition id -> CommitMetadata
private final ConcurrentHashMap<Integer, CommitMetadata> commitMetadataMap =
new ConcurrentHashMap<>();
JavaUtils.newConcurrentHashMap();
private final Map<String, LocationPushFailedBatches> failedBatchMap;