HBASE-26992 Brotli compressor has unexpected behavior during reinitialization (#4389)
Signed-off-by: Duo Zhang <zhangduo@apache.org>
This commit is contained in:
parent
f5a566ea1b
commit
152ecad53a
|
@ -162,8 +162,8 @@ public class BrotliCompressor implements CanReinit, Compressor {
|
||||||
int newBufferSize = BrotliCodec.getBufferSize(conf);
|
int newBufferSize = BrotliCodec.getBufferSize(conf);
|
||||||
if (bufferSize != newBufferSize) {
|
if (bufferSize != newBufferSize) {
|
||||||
bufferSize = newBufferSize;
|
bufferSize = newBufferSize;
|
||||||
this.inBuf = ByteBuffer.allocateDirect(bufferSize);
|
this.inBuf = ByteBuffer.allocate(bufferSize);
|
||||||
this.outBuf = ByteBuffer.allocateDirect(bufferSize);
|
this.outBuf = ByteBuffer.allocate(bufferSize);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
reset();
|
reset();
|
||||||
|
|
Loading…
Reference in New Issue