fix Compress memleak
This commit is contained in:
@ -153,10 +153,8 @@ int ObZstdCompressor_1_3_8::decompress(const char *src_buffer,
|
||||
|
||||
void ObZstdCompressor_1_3_8::reset_mem()
|
||||
{
|
||||
ObZstdCtxAllocator *zstd_allocator = GET_TSI_MULT(ObZstdCtxAllocator, 1);
|
||||
if (NULL != zstd_allocator) {
|
||||
zstd_allocator->reset();
|
||||
}
|
||||
ObZstdCtxAllocator &zstd_allocator = ObZstdCtxAllocator::get_thread_local_instance();
|
||||
zstd_allocator.reset();
|
||||
}
|
||||
|
||||
const char *ObZstdCompressor_1_3_8::get_compressor_name() const
|
||||
|
||||
Reference in New Issue
Block a user