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

Add some logs, for troubleshooting 4377 problem

Browse Source
This commit is contained in:
AntiTopQuark
2023-03-02 18:30:55 +00:00
committed by ob-robot
parent e1bbb36c43
commit 20d0d4661c
2 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/das/ob_das_scan_op.cpp
View File

@ -1024,6 +1024,8 @@ int ObLocalIndexLookupOp::check_lookup_row_cnt()
"index_group_cnt", get_index_group_cnt(), "index_group_cnt", get_index_group_cnt(),
"lookup_group_cnt", get_lookup_group_cnt(), "lookup_group_cnt", get_lookup_group_cnt(),
"scan_range", scan_param_.key_ranges_, "scan_range", scan_param_.key_ranges_,
"index_table_id", index_ctdef_->ref_table_id_ ,
"data_table_tablet_id", tablet_id_ ,
KPC_(lookup_ctdef), KPC_(lookup_rtdef)); KPC_(lookup_ctdef), KPC_(lookup_rtdef));
} }
} }

8
src/sql/engine/table/ob_table_scan_op.cpp
View File

@ -3257,13 +3257,17 @@ int ObGlobalIndexLookupOpImpl::check_lookup_row_cnt()
ObString func_name = ObString::make_string("check_lookup_row_cnt"); ObString func_name = ObString::make_string("check_lookup_row_cnt");
LOG_USER_ERROR(OB_ERR_DEFENSIVE_CHECK, func_name.length(), func_name.ptr()); LOG_USER_ERROR(OB_ERR_DEFENSIVE_CHECK, func_name.length(), func_name.ptr());
LOG_ERROR("Fatal Error!!! Catch a defensive error!", LOG_ERROR("Fatal Error!!! Catch a defensive error!",
K(ret), K_(lookup_rowkey_cnt), K_(lookup_row_cnt)); K(ret), K_(lookup_rowkey_cnt), K_(lookup_row_cnt),
"index_group_cnt", get_index_group_cnt(),
"lookup_group_cnt", get_lookup_group_cnt(),
"index_table_id", table_scan_op_->get_tsc_spec().get_ref_table_id());
//now to dump lookup das task info //now to dump lookup das task info
for (DASTaskIter task_iter = das_ref_.begin_task_iter(); !task_iter.is_end(); ++task_iter) { for (DASTaskIter task_iter = das_ref_.begin_task_iter(); !task_iter.is_end(); ++task_iter) {
ObDASScanOp *das_op = static_cast<ObDASScanOp*>(*task_iter); ObDASScanOp *das_op = static_cast<ObDASScanOp*>(*task_iter);
LOG_INFO("dump TableLookup DAS Task range", LOG_INFO("dump TableLookup DAS Task range",
"scan_range", das_op->get_scan_param().key_ranges_, "scan_range", das_op->get_scan_param().key_ranges_,
"range_array_pos", das_op->get_scan_param().range_array_pos_); "range_array_pos", das_op->get_scan_param().range_array_pos_,
"tablet_id", das_op->get_tablet_id());
} }
} }
} }