[incubator-celeborn] branch main updated: [CELEBORN-327][Flink] BufferStreamMananger should recycle buffer in reader thread. (#1261)

[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 1704aff9 [CELEBORN-327][Flink] BufferStreamMananger should recycle 
buffer in reader thread. (#1261)
1704aff9 is described below

commit 1704aff95cd0d1b98c1fc645a7c44ce23def5b89
Author: Ethan Feng <ethanf...@apache.org>
AuthorDate: Wed Feb 22 16:02:58 2023 +0800

    [CELEBORN-327][Flink] BufferStreamMananger should recycle buffer in reader 
thread. (#1261)
---
 .../org/apache/celeborn/common/network/server/BufferStreamManager.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/common/src/main/java/org/apache/celeborn/common/network/server/BufferStreamManager.java
 
b/common/src/main/java/org/apache/celeborn/common/network/server/BufferStreamManager.java
index 45c83cd3..3cd41eba 100644
--- 
a/common/src/main/java/org/apache/celeborn/common/network/server/BufferStreamManager.java
+++ 
b/common/src/main/java/org/apache/celeborn/common/network/server/BufferStreamManager.java
@@ -256,8 +256,7 @@ public class BufferStreamManager {
     public void recycle(ByteBuf buffer, Queue<ByteBuf> bufferQueue) {
       buffer.clear();
       bufferQueue.add(buffer);
-      // avoid unnecessary thread switch
-      readBuffers();
+      triggerRead();
     }
 
     public synchronized void readBuffers() {