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

[CP] Ignore duplicate primary key errors when inserting __wr_active_session_history

Browse Source
This commit is contained in:
AntiTopQuark 2024-11-28 12:44:30 +00:00 committed by ob-robot
parent 1118f19e2b
commit e012731a64
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/share/wr/ob_wr_collector.cpp
View File

@ -535,14 +535,28 @@ int ObWrCollector::collect_ash()
if (OB_SUCC(ret) && dml_splicer.get_row_count() >= WR_ASH_INSERT_BATCH_SIZE) {
collected_ash_row_count += dml_splicer.get_row_count();
if (OB_FAIL(write_to_wr(dml_splicer, OB_WR_ACTIVE_SESSION_HISTORY_TNAME, tenant_id))) {
LOG_WARN("failed to batch write to wr", KR(ret));
if (ret == OB_ERR_PRIMARY_KEY_DUPLICATE) {
ret = OB_SUCCESS;
collected_ash_row_count -= dml_splicer.get_row_count();
dml_splicer.reset();
LOG_WARN("failed to batch write to wr because of duplicated key", KR(ret));
} else {
LOG_WARN("failed to batch write to wr", KR(ret));
}
}
}
}
if (OB_SUCC(ret) && dml_splicer.get_row_count() > 0) {
collected_ash_row_count += dml_splicer.get_row_count();
if (OB_FAIL(write_to_wr(dml_splicer, OB_WR_ACTIVE_SESSION_HISTORY_TNAME, tenant_id))) {
LOG_WARN("failed to batch write remaining part to wr", KR(ret));
if (ret == OB_ERR_PRIMARY_KEY_DUPLICATE) {
ret = OB_SUCCESS;
collected_ash_row_count -= dml_splicer.get_row_count();
dml_splicer.reset();
LOG_WARN("failed to batch write to wr because of duplicated key", KR(ret));
} else {
LOG_WARN("failed to batch write to wr", KR(ret));
}
}
}
}