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

free slice_writer and slice_store earlier

Browse Source
This commit is contained in:
renju96
2024-01-24 09:42:53 +00:00
committed by ob-robot
parent fe813b29a4
commit 7ce4b0a202
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1756,14 +1756,14 @@ int ObTabletDirectLoadMgr::close_sstable_slice(
ObTabletObjLoadHelper::free(arena_allocator, storage_schema); ObTabletObjLoadHelper::free(arena_allocator, storage_schema);
} }
if (OB_NOT_NULL(slice_writer)) { if (OB_NOT_NULL(slice_writer)) {
if (is_data_direct_load(direct_load_type_) && slice_writer->need_column_store()) { if (OB_SUCC(ret) && is_data_direct_load(direct_load_type_) && slice_writer->need_column_store()) {
//ignore, free after rescan //ignore, free after rescan
} else { } else {
int tmp_ret = OB_SUCCESS; int tmp_ret = OB_SUCCESS;
if (OB_TMP_FAIL(sqc_build_ctx_.slice_mgr_map_.erase_refactored(slice_info.slice_id_))) { 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)); LOG_ERROR("erase failed", K(ret), K(tmp_ret), K(slice_info));
} else { } else {
LOG_INFO("erase a slice writer", KP(slice_writer), K(sqc_build_ctx_.slice_mgr_map_.size())); LOG_INFO("erase a slice writer", K(ret), KP(slice_writer), K(sqc_build_ctx_.slice_mgr_map_.size()));
slice_writer->~ObDirectLoadSliceWriter(); slice_writer->~ObDirectLoadSliceWriter();
sqc_build_ctx_.slice_writer_allocator_.free(slice_writer); sqc_build_ctx_.slice_writer_allocator_.free(slice_writer);
slice_writer = nullptr; slice_writer = nullptr;

3
src/storage/ddl/ob_direct_load_struct.cpp
View File

@ -1139,6 +1139,9 @@ int ObDirectLoadSliceWriter::fill_column_group(const ObStorageSchema *storage_sc
// 3. close writers // 3. close writers
if (OB_FAIL(cur_writer->close())) { if (OB_FAIL(cur_writer->close())) {
LOG_WARN("close co ddl writer failed", K(ret)); LOG_WARN("close co ddl writer failed", K(ret));
} else {
// 4. reset datum store (if fail, datum store will free when ~ObDirectLoadSliceWriter())
cur_datum_store->reset();
} }
} }
} }