[flink] branch release-1.12 updated: [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

[xt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

xtsong pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.12 by this push:
     new 60093e4  [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints
60093e4 is described below

commit 60093e4c51fd0e566e44c8ec7585a67c9376e164
Author: SteNicholas <pr...@163.com>
AuthorDate: Thu May 13 20:25:53 2021 +0800

    [FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints
    
    This closes #15915
---
 .../io/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 3b908db..1b790a9 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 @@ public class LocalRecoveredInputChannel extends RecoveredInputChannel {
                 initialBackoff,
                 maxBackoff,
                 numBytesIn,
-                numBytesIn,
+                numBuffersIn,
                 channelStateWriter);
     }
 }