[GitHub] [flink] zhijiangW commented on a change in pull request #12493: [FLINK-18139][checkpointing] Fixing unaligned checkpoints checks wrong channels for inflight data.

zhijiangW commented on a change in pull request #12493: URL: https://github.com/apache/flink/pull/12493#discussion_r435678966 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInputTest.java ## @@ -110,6 +118,69 @@ public

[GitHub] [flink] zhijiangW commented on a change in pull request #12493: [FLINK-18139][checkpointing] Fixing unaligned checkpoints checks wrong channels for inflight data.

zhijiangW commented on a change in pull request #12493: URL: https://github.com/apache/flink/pull/12493#discussion_r435674425 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java ## @@ -331,6 +331,7 @@ public

[GitHub] [flink] zhijiangW commented on a change in pull request #12493: [FLINK-18139][checkpointing] Fixing unaligned checkpoints checks wrong channels for inflight data.

zhijiangW commented on a change in pull request #12493: URL: https://github.com/apache/flink/pull/12493#discussion_r435674253 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java ## @@ -310,16 +310,16 @@