diff --git a/client/jdbc/src/main/java/com/dremio/exec/vector/accessor/VarBinaryAccessor.java b/client/jdbc/src/main/java/com/dremio/exec/vector/accessor/VarBinaryAccessor.java index 326e3d9050..6a96752b0b 100644 --- a/client/jdbc/src/main/java/com/dremio/exec/vector/accessor/VarBinaryAccessor.java +++ b/client/jdbc/src/main/java/com/dremio/exec/vector/accessor/VarBinaryAccessor.java @@ -65,7 +65,7 @@ public InputStream getStream(int index) { } NullableVarBinaryHolder h = new NullableVarBinaryHolder(); ac.get(index, h); - return new ByteBufInputStream(NettyArrowBuf.unwrapBuffer(h.buffer.slice(h.start, h.end))); + return new ByteBufInputStream(NettyArrowBuf.unwrapBuffer(h.buffer.slice(h.start, h.end - h.start))); } @Override diff --git a/client/jdbc/src/main/java/com/dremio/exec/vector/accessor/VarCharAccessor.java b/client/jdbc/src/main/java/com/dremio/exec/vector/accessor/VarCharAccessor.java index a2d8f1c1e2..5f39a1ca9b 100644 --- a/client/jdbc/src/main/java/com/dremio/exec/vector/accessor/VarCharAccessor.java +++ b/client/jdbc/src/main/java/com/dremio/exec/vector/accessor/VarCharAccessor.java @@ -53,7 +53,7 @@ public InputStream getStream(int index) { } NullableVarCharHolder h = new NullableVarCharHolder(); ac.get(index, h); - return new ByteBufInputStream(NettyArrowBuf.unwrapBuffer(h.buffer.slice(h.start, h.end))); + return new ByteBufInputStream(NettyArrowBuf.unwrapBuffer(h.buffer.slice(h.start, h.end - h.start))); } @Override