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

[CELEBORN-309] Fix some potential concurrent issues in InFlightRequestTracker (#1243)

Browse Source
This commit is contained in:
Keyong Zhou 2023-02-17 10:01:19 +08:00 committed by GitHub
parent 57f775a7e9
commit 89b4eab3b6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java
View File

@ -60,9 +60,6 @@ public class InFlightRequestTracker {
public void removeBatch(int batchId, String hostAndPushPort) {
Set<Integer> batchIdSet = inflightBatchesPerAddress.get(hostAndPushPort);
batchIdSet.remove(batchId);
if (batchIdSet.size() == 0) {
inflightBatchesPerAddress.remove(hostAndPushPort);
}
}
public void onSuccess(String hostAndPushPort) {