diff --git a/hbase-compression/hbase-compression-brotli/src/main/java/org/apache/hadoop/hbase/io/compress/brotli/BrotliCompressor.java b/hbase-compression/hbase-compression-brotli/src/main/java/org/apache/hadoop/hbase/io/compress/brotli/BrotliCompressor.java index c45eb0d1401..f6989064b76 100644 --- a/hbase-compression/hbase-compression-brotli/src/main/java/org/apache/hadoop/hbase/io/compress/brotli/BrotliCompressor.java +++ b/hbase-compression/hbase-compression-brotli/src/main/java/org/apache/hadoop/hbase/io/compress/brotli/BrotliCompressor.java @@ -162,8 +162,8 @@ public class BrotliCompressor implements CanReinit, Compressor { int newBufferSize = BrotliCodec.getBufferSize(conf); if (bufferSize != newBufferSize) { bufferSize = newBufferSize; - this.inBuf = ByteBuffer.allocateDirect(bufferSize); - this.outBuf = ByteBuffer.allocateDirect(bufferSize); + this.inBuf = ByteBuffer.allocate(bufferSize); + this.outBuf = ByteBuffer.allocate(bufferSize); } } reset();