hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix sql plan bug

Browse Source
This commit is contained in:
zzg19950727
2023-08-08 08:24:24 +00:00
committed by ob-robot
parent 6fd716e98c
commit d1e5895cb8
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/sql/monitor/ob_plan_info_manager.cpp
View File

@ -310,8 +310,15 @@ int ObLogicalPlanRawData::uncompress_logical_plan(ObIAllocator &allocator,
//do nothing //do nothing
} else if (uncompress_len_ < 0) { } else if (uncompress_len_ < 0) {
//do not need decompress //do not need decompress
uncompress_buf = logical_plan_;
uncompress_size = logical_plan_len_; uncompress_size = logical_plan_len_;
if (NULL == (uncompress_buf = (char*)allocator.alloc(uncompress_size))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
if (REACH_TIME_INTERVAL(100 * 1000)) {
LOG_WARN("alloc mem failed", K(uncompress_size), K(ret));
}
} else {
MEMCPY(uncompress_buf, logical_plan_, uncompress_size);
}
} else if (OB_FAIL(common::ObCompressorPool::get_instance().get_compressor(compressor_type, } else if (OB_FAIL(common::ObCompressorPool::get_instance().get_compressor(compressor_type,
compressor))) { compressor))) {
LOG_WARN("fail to get compressor", K(compressor_type), K(ret)); LOG_WARN("fail to get compressor", K(compressor_type), K(ret));