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

add log for compaction diagnose

Browse Source
This commit is contained in:
a1iive
2023-03-06 10:41:13 +00:00
committed by ob-robot
parent 0829d606a9
commit a40e181106
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/compaction/ob_compaction_diagnose.cpp
View File

@ -501,6 +501,7 @@ int ObCompactionDiagnoseMgr::diagnose_tenant_tablet()
} }
} }
} // end of while } // end of while
LOG_INFO("finish ls merge diagnose", K(ret), K(ls_id));
} }
} }
} // end of while } // end of while
@ -524,6 +525,8 @@ int ObCompactionDiagnoseMgr::diagnose_tenant_major_merge()
} else if (need_diagnose) { } else if (need_diagnose) {
if (OB_FAIL(do_tenant_major_merge_diagnose(major_freeze_service))) { if (OB_FAIL(do_tenant_major_merge_diagnose(major_freeze_service))) {
LOG_WARN("fail to do tenant major merge diagnose", KR(ret)); LOG_WARN("fail to do tenant major merge diagnose", KR(ret));
} else {
LOG_INFO("finish diagnose tenant major merge", K(ret));
} }
} }
} }
@ -576,6 +579,7 @@ int ObCompactionDiagnoseMgr::do_tenant_major_merge_diagnose(
LOG_WARN("fail to get uncompacted tablets", KR(ret)); LOG_WARN("fail to get uncompacted tablets", KR(ret));
} else { } else {
int64_t uncompacted_tablets_cnt = uncompacted_tablets.count(); int64_t uncompacted_tablets_cnt = uncompacted_tablets.count();
LOG_INFO("finish get uncompacted tablets for diagnose", K(ret), K(uncompacted_tablets_cnt));
for (int64_t i = 0; (OB_SUCCESS == ret) && i < uncompacted_tablets_cnt; ++i) { for (int64_t i = 0; (OB_SUCCESS == ret) && i < uncompacted_tablets_cnt; ++i) {
if (can_add_diagnose_info()) { if (can_add_diagnose_info()) {
if (OB_FAIL(SET_DIAGNOSE_INFO(info_array_[idx_++], MAJOR_MERGE, MTL_ID(), if (OB_FAIL(SET_DIAGNOSE_INFO(info_array_[idx_++], MAJOR_MERGE, MTL_ID(),