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

log simplify

Browse Source
This commit is contained in:
chaser-ch
2024-03-06 09:15:11 +00:00
committed by ob-robot
parent 210aa3cee7
commit 87e6201036
3 changed files with 11 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/compaction/ob_medium_compaction_func.cpp
View File

@ -851,7 +851,7 @@ int ObMediumCompactionScheduleFunc::prepare_medium_info(
LOG_WARN("failed to init parallel range", K(ret), K(medium_info)); LOG_WARN("failed to init parallel range", K(ret), K(medium_info));
} else { } else {
medium_info.last_medium_snapshot_ = result.handle_.get_table(0)->get_snapshot_version(); medium_info.last_medium_snapshot_ = result.handle_.get_table(0)->get_snapshot_version();
LOG_INFO("success to prepare medium info", K(ret), K(medium_info)); LOG_TRACE("success to prepare medium info", K(ret), K(medium_info));
} }
return ret; return ret;
} }

2
src/storage/compaction/ob_medium_compaction_mgr.cpp
View File

@ -273,7 +273,7 @@ int ObTabletMediumCompactionInfoRecorder::sync_clog_succ_for_leader(const int64_
} else if (OB_FAIL(submit_trans_on_mds_table(true/*is_commit*/))) { } else if (OB_FAIL(submit_trans_on_mds_table(true/*is_commit*/))) {
LOG_WARN("failed to dec ref on memtable", K(ret), K_(tablet_id), KPC(medium_info_)); LOG_WARN("failed to dec ref on memtable", K(ret), K_(tablet_id), KPC(medium_info_));
} else { } else {
FLOG_INFO("success to save medium info for leader", K(ret), K_(ls_id), K_(tablet_id), KPC(medium_info_), LOG_TRACE("success to save medium info for leader", K(ret), K_(ls_id), K_(tablet_id), KPC(medium_info_),
K(max_saved_version_), K_(clog_scn)); K(max_saved_version_), K_(clog_scn));
} }
return ret; return ret;

17
src/storage/compaction/ob_tenant_tablet_scheduler.cpp
View File

@ -1484,20 +1484,21 @@ bool ObTenantTabletScheduler::get_enable_adaptive_compaction()
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
bool enable_adaptive_compaction = enable_adaptive_compaction_; bool enable_adaptive_compaction = enable_adaptive_compaction_;
ObTenantSysStat cur_sys_stat; ObTenantSysStat cur_sys_stat;
if (!enable_adaptive_compaction_) { if (!enable_adaptive_compaction) {
// do nothing // do nothing
#ifdef ENABLE_DEBUG_LOG
} else if (GCONF.enable_crazy_medium_compaction) {
enable_adaptive_compaction = true;
LOG_DEBUG("set crazy medium, set enable_adaptive_compaction = true");
#endif
} else if (OB_FAIL(MTL(ObTenantTabletStatMgr *)->get_sys_stat(cur_sys_stat))) { } else if (OB_FAIL(MTL(ObTenantTabletStatMgr *)->get_sys_stat(cur_sys_stat))) {
LOG_WARN("failed to get tenant sys stat", K(ret), K(cur_sys_stat)); LOG_WARN("failed to get tenant sys stat", K(ret), K(cur_sys_stat));
} else if (cur_sys_stat.is_full_cpu_usage()) { } else if (cur_sys_stat.is_full_cpu_usage()) {
enable_adaptive_compaction = false; enable_adaptive_compaction = false;
FLOG_INFO("disable adaptive compaction due to the high load CPU", K(ret), K(cur_sys_stat)); if (REACH_TENANT_TIME_INTERVAL(PRINT_LOG_INVERVAL)) {
FLOG_INFO("disable adaptive compaction due to the high load CPU", K(ret), K(cur_sys_stat));
}
} }
#ifdef ENABLE_DEBUG_LOG
if (GCONF.enable_crazy_medium_compaction) {
enable_adaptive_compaction = true;
LOG_DEBUG("set crazy medium, set enable_adaptive_compaction = true");
}
#endif
return enable_adaptive_compaction; return enable_adaptive_compaction;
} }