rkhachatryan commented on a change in pull request #14052:
URL: https://github.com/apache/flink/pull/14052#discussion_r526309425
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
##########
@@ -98,14 +100,11 @@
private final BufferManager bufferManager;
- /**
- * Indicates the last overtaken sequence number by the most recent
{@link CheckpointBarrier}
- * before task thread started checkpoint, or {@code null} if {@link
CheckpointBarrier} hasn't
- * arrived yet.
- */
@GuardedBy("receivedBuffers")
- @Nullable
- private Integer lastOvertakenSequenceNumber = null;
+ private int lastBarrierSequenceNumber = NONE;
Review comment:
It would be easier I think for us to unroll the history later if needed.
But I don't insist, moved type change to Piotr's commit.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
