pnowojski commented on a change in pull request #9062: [FLINK-13100][network]
Fix the bug of throwing IOException while FileChannelBoundedData#nextBuffer
URL: https://github.com/apache/flink/pull/9062#discussion_r302527969
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionReader.java
##########
@@ -89,9 +114,30 @@ public BufferAndBacklog getNextBuffer() throws IOException
{
return BufferAndBacklog.fromBufferAndLookahead(current,
nextBuffer, dataBufferBacklog);
}
+ /**
+ * This method is actually only meaningful for the {@link
BoundedBlockingSubpartitionType#FILE}. For the
+ * other types the next buffer is always not null while {@link
ResultSubpartitionView#getNextBuffer()},
Review comment:
I meant to slightly rephrase the comment from:
> For the other types the next buffer is always not null while
`ResultSubpartitionView#getNextBuffer()`
to:
> For the other types the {@link #nextBuffer} can not be ever set to null,
so it is (...)
The `checkState` comment is a nit, lets ignore it for now.
----------------------------------------------------------------
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]
With regards,
Apache Git Services
