From 0fa29a2e66df7afd64d87d4edd70e6f66335352a Mon Sep 17 00:00:00 2001
From: SteNicholas <programgeek@163.com>
Date: Thu, 13 May 2021 20:25:53 +0800
Subject: [PATCH] [FLINK-22592][runtime] numBuffersInLocal is always zero when
 using unaligned checkpoints

---
 .../network/partition/consumer/LocalRecoveredInputChannel.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);
     }
 }