You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@celeborn.apache.org by et...@apache.org on 2023/03/09 04:31:14 UTC
[incubator-celeborn] branch main updated: [CELEBORN-387][FLINK] Remove unnecessary limitZeroInFlight from sendMessageInternal. (#1319)
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 8e167c648 [CELEBORN-387][FLINK] Remove unnecessary limitZeroInFlight from sendMessageInternal. (#1319)
8e167c648 is described below
commit 8e167c64880105ffc344e510148bad1516c9295d
Author: Ethan Feng <et...@apache.org>
AuthorDate: Thu Mar 9 12:31:09 2023 +0800
[CELEBORN-387][FLINK] Remove unnecessary limitZeroInFlight from sendMessageInternal. (#1319)
---
.../apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java b/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java
index 36e52937b..ea0b6e88b 100644
--- a/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java
+++ b/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java
@@ -472,8 +472,6 @@ public class FlinkShuffleClientImpl extends ShuffleClientImpl {
return null;
}
pushState = getPushState(mapKey);
- // force data has been send
- limitZeroInFlight(mapKey, pushState);
// add inFlight requests
batchId = pushState.nextBatchId();