diff --git a/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java b/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java
index e57ea792f8e..7f478143dfb 100644
--- a/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java
+++ b/client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java
@@ -100,10 +100,12 @@ public void onSuccess(ByteBuffer response) {
 
           @Override
           public void onFailure(Throwable e) {
-            logger.warn(
-                "Send PbReadAddCredit to {} failed, detail {}",
+            logger.error(
+                "Send PbReadAddCredit to {} failed, streamId {}, detail {}",
                 NettyUtils.getRemoteAddress(client.getChannel()),
+                streamId,
                 e.getCause());
+            messageConsumer.accept(new TransportableError(streamId, e));
           }
         });
   }