diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalRecoveredInputChannel.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalRecoveredInputChannel.java
index 3b908db93f5fa..1b790a9e91e5c 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalRecoveredInputChannel.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalRecoveredInputChannel.java
@@ -68,7 +68,7 @@ protected InputChannel toInputChannelInternal() {
                 initialBackoff,
                 maxBackoff,
                 numBytesIn,
-                numBytesIn,
+                numBuffersIn,
                 channelStateWriter);
     }
 }