diff --git a/backend/src/main/java/com/bakdata/conquery/io/mina/ChunkWriter.java b/backend/src/main/java/com/bakdata/conquery/io/mina/ChunkWriter.java index c5d98253cc..727ebd9e2f 100644 --- a/backend/src/main/java/com/bakdata/conquery/io/mina/ChunkWriter.java +++ b/backend/src/main/java/com/bakdata/conquery/io/mina/ChunkWriter.java @@ -59,7 +59,7 @@ private void newBuffer(int required) { private void finishBuffer(boolean end) { buffer.flip(); - if (buffer.remaining() - HEADER_SIZE <= 0) { + if (buffer.remaining() < HEADER_SIZE) { throw new IllegalStateException("Buffer of size %s is too small for header of length %s".formatted(buffer.remaining(), HEADER_SIZE)); } buffer.put(0, end ? LAST_MESSAGE : CONTINUED_MESSAGE);