[FLINK-22592][runtime] numBuffersInLocal is always zero when using un…

…aligned checkpoints This closes apache#15915
tongcheng-elong · May 17, 2021 · 6c62561 · 6c62561
1 parent 5ff7f73
commit 6c62561
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...va/org/apache/flink/runtime/io/network/partition/consumer/LocalRecoveredInputChannel.java b/...va/org/apache/flink/runtime/io/network/partition/consumer/LocalRecoveredInputChannel.java
@@ -68,7 +68,7 @@ protected InputChannel toInputChannelInternal() {
  initialBackoff,
  maxBackoff,
  numBytesIn,
- numBytesIn,
+ numBuffersIn,
  channelStateWriter);
  }
 }