From cce1a34cc56cba193aa628624bcd74934d86788b Mon Sep 17 00:00:00 2001 From: obdev Date: Tue, 6 Feb 2024 18:57:54 +0000 Subject: [PATCH] add log --- src/sql/engine/px/ob_px_task_process.cpp | 4 ++-- src/sql/engine/px/ob_px_util.cpp | 17 +++++++++++++++-- 2 files changed, 17 insertions(+), 4 deletions(-) diff --git a/src/sql/engine/px/ob_px_task_process.cpp b/src/sql/engine/px/ob_px_task_process.cpp index 5c19e6b2ec..35c03cd430 100644 --- a/src/sql/engine/px/ob_px_task_process.cpp +++ b/src/sql/engine/px/ob_px_task_process.cpp @@ -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; diff --git a/src/sql/engine/px/ob_px_util.cpp b/src/sql/engine/px/ob_px_util.cpp index e9d8e04457..f4584b2dff 100644 --- a/src/sql/engine/px/ob_px_util.cpp +++ b/src/sql/engine/px/ob_px_util.cpp @@ -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; ObSEArraybase_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; }