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

refine log

Browse Source
This commit is contained in:
chaser-ch 2025-01-02 11:15:24 +00:00 committed by ob-robot
parent 926b77d761
commit e0e8ab0dc5
6 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/share/scheduler/ob_tenant_dag_scheduler.cpp
View File

@ -1759,7 +1759,7 @@ void ObTenantDagWorker::run1()
} else if (ObDagType::DAG_TYPE_MINI_MERGE == dag->get_type()
&& static_cast<compaction::ObTabletMergeDag *>(dag)->is_reserve_mode()) {
is_reserve_mode_ = true;
COMMON_LOG(INFO, "Mini compaction enter reserve mode", KPC(dag));
COMMON_LOG(TRACE, "Mini compaction enter reserve mode", KPC(dag));
}
if (OB_SUCC(ret)) {

5
src/storage/compaction/ob_basic_tablet_merge_ctx.cpp
View File

@ -417,7 +417,7 @@ int ObBasicTabletMergeCtx::prepare_merge_progress(
progress->reset();
LOG_WARN("failed to init merge progress", K(ret));
} else {
LOG_INFO("succeed to init merge progress", K(ret), KPC(progress));
LOG_TRACE("succeed to init merge progress", K(ret), KPC(progress));
}
if (OB_FAIL(ret) && nullptr != progress) {
progress->~ObPartitionMergeProgress();
@ -750,7 +750,6 @@ int ObBasicTabletMergeCtx::generate_macro_id_list(char *buf, const int64_t buf_l
if (macro_count < 40) {
MacroBlockId macro_id;
for (int64_t i = 0; OB_SUCC(ret) && OB_SUCC(iter.get_next_macro_id(macro_id)); ++i) {
LOG_INFO("print macro id", K(macro_id));
const int64_t block_seq = is_local_exec_mode(get_exec_mode())
? (GCTX.is_shared_storage_mode() ? macro_id.tenant_seq() : macro_id.second_id())
: macro_id.third_id();
@ -880,7 +879,7 @@ int ObBasicTabletMergeCtx::init_static_param_and_desc()
static_param_.encoding_granularity_))) {
LOG_WARN("failed to init static desc", KR(ret), KPC(this));
} else {
LOG_INFO("[SharedStorage] success to set exec mode", KR(ret), "exec_mode", exec_mode_to_str(static_desc_.exec_mode_));
LOG_TRACE("[SharedStorage] success to set exec mode", KR(ret), "exec_mode", exec_mode_to_str(static_desc_.exec_mode_));
}
return ret;
}

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

@ -232,7 +232,7 @@ int ObPartitionMergeProgress::inner_init_estimated_vals()
} else {
avg_row_length_ = estimated_total_size_ * 1.0 / estimated_total_row_cnt_;
update_estimated_finish_time(0/*cur scanned row cnt*/);
LOG_INFO("success to estimate initial vals", K(ret), "param", ctx_->static_param_, KPC(this));
LOG_TRACE("success to estimate initial vals", K(ret), "param", ctx_->static_param_, KPC(this));
}
return ret;
}

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

@ -291,7 +291,7 @@ int ObSSTableRebuilder::build_res_with_rewrite_macros(
} else if (OB_FAIL(index_builder.close_with_macro_seq(
res, macro_start_seq, OB_DEFAULT_MACRO_BLOCK_SIZE/*nested_size*/, 0/*nested_offset*/, pre_warm_param))) {
STORAGE_LOG(WARN, "fail to close", K(ret), K(index_builder));
} else {
} else if (!is_local_exec_mode(merge_param.get_exec_mode())) {
STORAGE_LOG(INFO, "success to close index builder", KR(ret), K(macro_start_seq), K(input_macro_seq));
}
return ret;

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

@ -277,7 +277,9 @@ int ObTenantFreezeInfoMgr::get_freeze_info_behind_snapshot_version(
if (OB_FAIL(ret)) {
STORAGE_LOG(WARN, "get_lock failed", KR(ret));
} else if (OB_FAIL(get_freeze_info_compare_with_snapshot_version_(snapshot_version, share::ObFreezeInfoManager::CmpType::GREATER_THAN, freeze_info))) {
STORAGE_LOG(WARN, "failed to get freeze info behind snapshot version", KR(ret), K(snapshot_version));
if (OB_ENTRY_NOT_EXIST != ret) {
STORAGE_LOG(WARN, "failed to get freeze info behind snapshot version", KR(ret), K(snapshot_version));
}
}
return ret;
}

4
src/storage/tablet/ob_tablet.cpp
View File

@ -455,6 +455,7 @@ int ObTablet::init_for_merge(
ObStorageSchema *old_storage_schema = nullptr;
const bool need_report_major = param.need_report_major();
const bool is_convert_co_merge = is_convert_co_major_merge(param.compaction_info_.merge_type_);
const bool is_mini = is_mini_merge(param.compaction_info_.merge_type_);
if (OB_UNLIKELY(is_inited_)) {
ret = OB_INIT_TWICE;
@ -467,6 +468,9 @@ int ObTablet::init_for_merge(
|| OB_ISNULL(log_handler_)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("tablet pointer handle is invalid", K(ret), K_(pointer_hdl), K_(log_handler));
} else if (is_mini && param.get_clog_checkpoint_scn() <= old_tablet.tablet_meta_.clog_checkpoint_scn_) {
ret = OB_NO_NEED_MERGE;
LOG_WARN("no need merge due to new tablet meta", KR(ret), K(param), K(old_tablet));
} else if (param.get_need_check_transfer_seq() && OB_FAIL(check_transfer_seq_equal(old_tablet, param.get_transfer_seq()))) {
LOG_WARN("failed to check transfer seq eq", K(ret), K(old_tablet), K(param));
} else if (OB_FAIL(old_tablet.get_max_sync_storage_schema_version(max_sync_schema_version))) {