[incubator-celeborn] branch main updated: [CELEBORN-309] Fix some potential concurrent issues in InFlightRequestTracker (#1243)

[ethanfeng]

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

ethanfeng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new 89b4eab3 [CELEBORN-309] Fix some potential concurrent issues in 
InFlightRequestTracker (#1243)
89b4eab3 is described below

commit 89b4eab3b6f3c2bea0f4cc40eb8b8fa09fb53817
Author: Keyong Zhou <zho...@apache.org>
AuthorDate: Fri Feb 17 10:01:19 2023 +0800

    [CELEBORN-309] Fix some potential concurrent issues in 
InFlightRequestTracker (#1243)
---
 .../java/org/apache/celeborn/common/write/InFlightRequestTracker.java  | 3 ---
 1 file changed, 3 deletions(-)

diff --git 
a/common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java
 
b/common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java
index c8c4d845..3b3e8da6 100644
--- 
a/common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java
+++ 
b/common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java
@@ -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) {