diff options
author | Tor Brede Vekterli <vekterli@yahoo-inc.com> | 2017-06-09 17:52:33 +0200 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@yahoo-inc.com> | 2017-06-12 15:16:33 +0200 |
commit | d165ec86d13eb7ba8635db3408148e82b7456368 (patch) | |
tree | d798ba990ff6b6a91d5c6c8d4a550c931f096555 /vespajlib/src | |
parent | 9a6d1fc6f5635fe917d1a563149764be12822ffc (diff) |
Compressor must only compress actual input range, not entire array
Diffstat (limited to 'vespajlib/src')
-rw-r--r-- | vespajlib/src/main/java/com/yahoo/compress/Compressor.java | 2 |
1 files changed, 1 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 681f95142ab..4cdade4de01 100644 --- a/vespajlib/src/main/java/com/yahoo/compress/Compressor.java +++ b/vespajlib/src/main/java/com/yahoo/compress/Compressor.java @@ -80,7 +80,7 @@ public class Compressor { int dataSize = uncompressedSize.isPresent() ? uncompressedSize.get() : data.length; if (dataSize < compressMinSizeBytes) return new Compression(CompressionType.INCOMPRESSIBLE, dataSize, data); LZ4Compressor compressor = level < 7 ? factory.fastCompressor() : factory.highCompressor(); - byte[] compressedData = compressor.compress(data); + byte[] compressedData = compressor.compress(data, 0, dataSize); if (compressedData.length + 8 >= dataSize * compressionThresholdFactor) return new Compression(CompressionType.INCOMPRESSIBLE, dataSize, data); return new Compression(CompressionType.LZ4, dataSize, compressedData); |