[incubator-celeborn] branch main updated: [CELEBORN-353][FLINK] Fix incorrect read buffer metric. (#1288)

[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 d4af8fd09 [CELEBORN-353][FLINK] Fix incorrect read buffer metric. 
(#1288)
d4af8fd09 is described below

commit d4af8fd094eee0c98a13376706db8e0009107544
Author: Ethan Feng <ethanf...@apache.org>
AuthorDate: Wed Mar 1 11:08:13 2023 +0800

    [CELEBORN-353][FLINK] Fix incorrect read buffer metric. (#1288)
---
 .../celeborn/common/network/server/memory/ReadBufferDispatcher.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/common/src/main/java/org/apache/celeborn/common/network/server/memory/ReadBufferDispatcher.java
 
b/common/src/main/java/org/apache/celeborn/common/network/server/memory/ReadBufferDispatcher.java
index ecaddb72d..e3a198755 100644
--- 
a/common/src/main/java/org/apache/celeborn/common/network/server/memory/ReadBufferDispatcher.java
+++ 
b/common/src/main/java/org/apache/celeborn/common/network/server/memory/ReadBufferDispatcher.java
@@ -71,7 +71,7 @@ public class ReadBufferDispatcher extends Thread {
         int bufferSize = request.getBufferSize();
         while (buffers.size() < request.getMin()) {
           if (memoryManager.readBufferAvailable(bufferSize)) {
-            memoryManager.incrementDiskBuffer(bufferSize);
+            memoryManager.changeReadBufferCounter(bufferSize);
             ByteBuf buf = readBufferAllocator.buffer(bufferSize, bufferSize);
             buffers.add(buf);
           } else {