[FLINK-22592][runtime] numBuffersInLocal is always zero when using unaligned checkpoints

SteNicholas · xintongsong · commit 60093e4c51fd · 2021-05-17T11:16:19.000+08:00
This closes #15915
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
@@ -68,7 +68,7 @@ protected InputChannel toInputChannelInternal() {
                 initialBackoff,
                 maxBackoff,
                 numBytesIn,
-                numBytesIn,
+                numBuffersIn,
                 channelStateWriter);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ protected InputChannel toInputChannelInternal() {`
`68`	`68`	`initialBackoff,`
`69`	`69`	`maxBackoff,`
`70`	`70`	`numBytesIn,`
`71`		`- numBytesIn,`
	`71`	`+ numBuffersIn,`
`72`	`72`	`channelStateWriter);`
`73`	`73`	`}`
`74`	`74`	`}`