Hi Animesh,
The original code does look incorrect. My $0.02 is that we should maintain the
semantics of `write` of the underlying channel, i.e., if the underlying channel
is non-blocking, this class should e non-blocking too.
i.e.
```
public long write(ByteBuffer buffer) throws IOException {
long length = buffer.remaining();
LOGGER.debug("Writing buffer with size: " + length);
long written = out.write(buffer);
currentPosition += written;
return written;
}
```
@BryanCutler @jacques-n WDYT?
[ Full content available at: https://github.com/apache/arrow/pull/2594 ]
This message was relayed via gitbox.apache.org for [email protected]
