Skip to content

Commit fc97081

Browse files
authored
Fix compression
After extensive testing it was determined that under all circumstances Deflater def = new Deflater(); def.setLevel(Deflater.BEST_SPEED); results in no compression. The input data does not matter, nor does the level being set, providing it is different to the existing level. However, Deflater def = new Deflater(Deflater.BEST_SPEED); always works with no issues. Updated the code to reflect this.
2 parents ed66ae5 + bb101d7 commit fc97081

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

client/src/com/aerospike/client/command/Command.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2210,9 +2210,8 @@ protected final void end() {
22102210

22112211
private final void compress(Policy policy) {
22122212
if (policy.compress && dataOffset > COMPRESS_THRESHOLD) {
2213-
Deflater def = new Deflater();
2213+
Deflater def = new Deflater(Deflater.BEST_SPEED);
22142214
try {
2215-
def.setLevel(Deflater.BEST_SPEED);
22162215
def.setInput(dataBuffer, 0, dataOffset);
22172216
def.finish();
22182217

0 commit comments

Comments
 (0)