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

add log

Browse Source
This commit is contained in:
sdc
2023-11-21 08:15:00 +00:00
committed by ob-robot
parent 27f4d30d2e
commit 78ee253c39
2 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/engine/px/ob_px_task_process.cpp
View File

@ -174,7 +174,7 @@ int ObPxTaskProcess::process()
exec_start_timestamp_ = enqueue_timestamp_;
if (OB_FAIL(do_process())) {
LOG_WARN("failed to process", K(get_tenant_id()), K(ret));
LOG_WARN("failed to process", K(get_tenant_id()), K(ret), K(get_qc_id()), K(get_dfo_id()));
}
//监控项统计结束
@ -446,7 +446,7 @@ int ObPxTaskProcess::do_process()
arg_.exec_ctx_->get_my_session()->get_process_query_time());
ObExtraServerAliveCheck::Guard check_guard(*arg_.exec_ctx_, qc_alive_checker);
if (OB_FAIL(execute(*arg_.op_spec_root_))) {
LOG_WARN("failed to execute plan", K(ret));
LOG_WARN("failed to execute plan", K(ret), K(arg_.op_spec_root_->id_));
}
} else {
ret = OB_ERR_UNEXPECTED;

17
src/sql/engine/px/ob_px_util.cpp
View File

@ -973,7 +973,9 @@ int ObPXServerAddrUtil::set_dfo_accessed_location(ObExecContext &ctx,
ObDASTableLoc *dml_loc)
{
int ret = OB_SUCCESS;
ObDASTableLoc *dml_table_loc = nullptr;
ObTableID dml_table_location_key = OB_INVALID_ID;
ObTableID dml_ref_table_id = OB_INVALID_ID;
ObSEArray<int64_t, 2>base_order;
// 处理insert op 对应的partition location信息
if (OB_FAIL(ret) || OB_ISNULL(dml_op)) {
@ -1010,8 +1012,10 @@ int ObPXServerAddrUtil::set_dfo_accessed_location(ObExecContext &ctx,
dfo, base_order, table_loc, dml_op))) {
LOG_WARN("failed to set sqc accessed location", K(ret));
}
dml_table_loc = table_loc;
dml_table_location_key = table_location_key;
dml_ref_table_id = ref_table_id;
}
// 处理tsc对应的partition location信息
for (int64_t i = 0; OB_SUCC(ret) && i < scan_ops.count(); ++i) {
ObDASTableLoc *table_loc = nullptr;
@ -1039,6 +1043,15 @@ int ObPXServerAddrUtil::set_dfo_accessed_location(ObExecContext &ctx,
K(ref_table_id), KPC(table_loc));
}
} // end for
if (OB_FAIL(ret)) {
if (NULL == dml_op) {
LOG_WARN("set dfo accessed location failed, dml op is null", K(base_table_location_key), K(dfo));
} else {
LOG_WARN("set dfo accessed location failed, dml op is not null", K(base_table_location_key),
K(dml_op), K(dml_op->is_table_location_uncertain()), K(dml_table_location_key),
K(dml_ref_table_id), KPC(dml_table_loc));
}
}
return ret;
}