diff --git a/src/java/org/apache/cassandra/transport/CBUtil.java b/src/java/org/apache/cassandra/transport/CBUtil.java index e6ba02967f..6ad468253b 100644 --- a/src/java/org/apache/cassandra/transport/CBUtil.java +++ b/src/java/org/apache/cassandra/transport/CBUtil.java @@ -330,8 +330,11 @@ public abstract class CBUtil return; } - cb.writeInt(bytes.remaining()); - cb.writeBytes(bytes.duplicate()); + int remaining = bytes.remaining(); + cb.writeInt(remaining); + + if (remaining > 0) + cb.writeBytes(bytes.duplicate()); } public static int sizeOfValue(byte[] bytes)