diff options
-rw-r--r-- | vespajlib/src/main/java/com/yahoo/compress/Compressor.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/vespajlib/src/main/java/com/yahoo/compress/Compressor.java b/vespajlib/src/main/java/com/yahoo/compress/Compressor.java index 1b20f1dcaf7..eacb0f2c406 100644 --- a/vespajlib/src/main/java/com/yahoo/compress/Compressor.java +++ b/vespajlib/src/main/java/com/yahoo/compress/Compressor.java @@ -89,7 +89,9 @@ public class Compressor { case NONE: return compact(CompressionType.NONE, data, offset, len); case LZ4: - if (len < compressMinSizeBytes) return new Compression(CompressionType.INCOMPRESSIBLE, len, data); + if (len < compressMinSizeBytes) { + return compact(CompressionType.INCOMPRESSIBLE, data, offset, len); + } byte[] compressedData = getCompressor().compress(data, offset, len); if (compressedData.length + 8 >= len * compressionThresholdFactor) { return compact(CompressionType.INCOMPRESSIBLE, data, offset, len); |