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_r301965139
##########
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:
```
For the other types the {@link #nextBuffer} can not be ever set to null, so
it is (...)
```
also if that's true, I think we would need a checkState whenever we set
`nextBuffer` to `null`?
----------------------------------------------------------------
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
