diff --git a/src/main/java/org/xerial/snappy/SnappyOutputStream.java b/src/main/java/org/xerial/snappy/SnappyOutputStream.java index 6041767..56c073a 100755 --- a/src/main/java/org/xerial/snappy/SnappyOutputStream.java +++ b/src/main/java/org/xerial/snappy/SnappyOutputStream.java @@ -232,7 +232,7 @@ public class SnappyOutputStream extends OutputStream { */ public void rawWrite(Object array, int byteOffset, int byteLength) throws IOException { - if(inputCursor + byteLength < MIN_BLOCK_SIZE) { + if(inputCursor + byteLength < blockSize) { // copy the input data to uncompressed buffer Snappy.arrayCopy(array, byteOffset, byteLength, inputBuffer, inputCursor); inputCursor += byteLength;