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

free slice writer after fill column group data

Browse Source
This commit is contained in:
simonjoylet
2024-07-01 07:04:57 +00:00
committed by ob-robot
parent a23bcd2c9c
commit 801e751520
1 changed files with 8 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/storage/ddl/ob_direct_insert_sstable_ctx_new.cpp
View File

@ -2038,21 +2038,16 @@ int ObTabletDirectLoadMgr::close_sstable_slice(
}
}
if (OB_NOT_NULL(slice_writer)) {
if (OB_SUCC(ret) && is_data_direct_load(direct_load_type_) && slice_writer->need_column_store()) {
//ignore, free after rescan
int tmp_ret = OB_SUCCESS;
if (OB_TMP_FAIL(sqc_build_ctx_.slice_mgr_map_.erase_refactored(slice_info.slice_id_))) {
LOG_ERROR("erase failed", K(ret), K(tmp_ret), K(slice_info));
} else {
// for ddl, delete slice_writer regardless of success or failure
int tmp_ret = OB_SUCCESS;
if (OB_TMP_FAIL(sqc_build_ctx_.slice_mgr_map_.erase_refactored(slice_info.slice_id_))) {
LOG_ERROR("erase failed", K(ret), K(tmp_ret), K(slice_info));
} else {
LOG_INFO("erase a slice writer", K(ret), KP(slice_writer), K(sqc_build_ctx_.slice_mgr_map_.size()));
slice_writer->~ObDirectLoadSliceWriter();
sqc_build_ctx_.slice_writer_allocator_.free(slice_writer);
slice_writer = nullptr;
}
ret = OB_SUCC(ret) ? tmp_ret : ret;
LOG_INFO("erase a slice writer", K(ret), KP(slice_writer), K(sqc_build_ctx_.slice_mgr_map_.size()));
slice_writer->~ObDirectLoadSliceWriter();
sqc_build_ctx_.slice_writer_allocator_.free(slice_writer);
slice_writer = nullptr;
}
ret = OB_SUCC(ret) ? tmp_ret : ret;
}
}
return ret;