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

init direct_load_inc hash set in the function of assign

Browse Source
This commit is contained in:
KyrielightWei 2024-04-26 10:50:53 +00:00 committed by ob-robot
parent 7637863c6d
commit 30748ceed7
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/storage/tx/ob_direct_load_tx_ctx_define.cpp
View File

@ -320,14 +320,22 @@ int ObDLIBatchSet::assign(const ObDLIBatchSet &other)
{
int ret = OB_SUCCESS;
reuse();
ObDLIBatchSet::const_iterator iter = other.begin();
ObMemAttr mem_attr(MTL_ID(), "DLI_BATCH_HASH");
if (!other.created() || other.empty()) {
reuse();
// do nothing
} else if (!created() && OB_FAIL(create(32, mem_attr, mem_attr))) {
TRANS_LOG(WARN, "create batch hash set failed", K(ret));
} else {
reuse();
ObDLIBatchSet::const_iterator iter = other.begin();
while (iter != other.end() && OB_SUCC(ret)) {
if (OB_FAIL(set_refactored(iter->first, 1))) {
TRANS_LOG(WARN, "overwrite existed batch_info failed", K(ret), K(iter->first));
while (iter != other.end() && OB_SUCC(ret)) {
if (OB_FAIL(set_refactored(iter->first, 1))) {
TRANS_LOG(WARN, "overwrite existed batch_info failed", K(ret), K(iter->first));
}
iter++;
}
iter++;
}
return ret;