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

fix tmp file flush mgr fail to reserve space for array

Browse Source
This commit is contained in:
dongb0
2024-09-02 03:36:30 +00:00
committed by ob-robot
parent 454c15e162
commit c80dadc178
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/storage/tmp_file/ob_tmp_file_flush_ctx.cpp
View File

@ -81,14 +81,20 @@ int ObTmpFileBatchFlushContext::prepare_flush_ctx(
} else if (OB_ISNULL(prio_mgr) || OB_ISNULL(flush_monitor)) {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", KR(ret), KP(prio_mgr), KP(flush_monitor));
} else if (OB_FAIL(iter_.init(prio_mgr))) {
LOG_WARN("failed to init iterator", KR(ret), K(*this));
} else if (OB_FAIL(flush_failed_array_.reserve(MAX_COPY_FAIL_COUNT))) {
LOG_WARN("fail to reserve flush filed array", KR(ret), K(*this));
} else if (OB_FAIL(iter_.init(prio_mgr))) {
LOG_WARN("failed to init iterator", KR(ret), K(*this));
} else {
expect_flush_size_ = expect_flush_size;
flush_monitor_ptr_ = flush_monitor;
}
if (OB_FAIL(ret)) {
flush_failed_array_.reset();
iter_.reset();
LOG_INFO("failed to prepare flush ctx, rollback ctx", KR(ret), KPC(this));
}
return ret;
}