diff --git a/src/sql/das/ob_das_extra_data.cpp b/src/sql/das/ob_das_extra_data.cpp index 609a5c7f2..4bf7c45f7 100644 --- a/src/sql/das/ob_das_extra_data.cpp +++ b/src/sql/das/ob_das_extra_data.cpp @@ -51,7 +51,6 @@ int ObDASExtraData::init(const int64_t task_id, int ObDASExtraData::fetch_result() { int ret = OB_SUCCESS; - NG_TRACE(fetch_das_extra_result_begin); FLTSpanGuard(fetch_das_extra_result); ObDASDataFetchReq req; int64_t tenant_id = MTL_ID(); @@ -74,7 +73,6 @@ int ObDASExtraData::fetch_result() LOG_TRACE("das fetch task result", KR(ret), K(req), K(result_)); has_more_ = result_.has_more(); } - NG_TRACE(fetch_das_extra_result_end); return ret; } diff --git a/src/sql/das/ob_das_ref.cpp b/src/sql/das/ob_das_ref.cpp index 0151def90..5dcebc0a8 100644 --- a/src/sql/das/ob_das_ref.cpp +++ b/src/sql/das/ob_das_ref.cpp @@ -468,7 +468,6 @@ int ObDASRef::close_all_task() int ret = OB_SUCCESS; int last_end_ret = OB_SUCCESS; if (has_task()) { - NG_TRACE(close_das_task_begin); FLTSpanGuard(close_das_task); ObSQLSessionInfo *session = nullptr; @@ -506,7 +505,6 @@ int ObDASRef::close_all_task() if (task_map_.created()) { task_map_.destroy(); } - NG_TRACE(close_das_task_end); } return ret; } diff --git a/src/sql/das/ob_das_rpc_processor.cpp b/src/sql/das/ob_das_rpc_processor.cpp index fa3ef072a..21a3f5156 100644 --- a/src/sql/das/ob_das_rpc_processor.cpp +++ b/src/sql/das/ob_das_rpc_processor.cpp @@ -185,12 +185,10 @@ int ObDASSyncAccessP::process() { int ret = OB_SUCCESS; LOG_DEBUG("DAS sync access remote process", K_(arg)); - NG_TRACE(das_sync_rpc_process_begin); FLTSpanGuard(das_sync_rpc_process); if (OB_FAIL(ObDASSyncRpcProcessor::process())) { LOG_WARN("failed to process das sync rpc", K(ret)); } - NG_TRACE(das_sync_rpc_process_end); return OB_SUCCESS; } @@ -198,12 +196,10 @@ int ObDASAsyncAccessP::process() { int ret = OB_SUCCESS; LOG_DEBUG("DAS async access remote process", K_(arg)); - NG_TRACE(das_async_rpc_process_begin); FLTSpanGuard(das_async_rpc_process); if (OB_FAIL(ObDASAsyncRpcProcessor::process())) { LOG_WARN("failed to process das async rpc", K(ret)); } - NG_TRACE(das_async_rpc_process_end); return OB_SUCCESS; } @@ -269,7 +265,6 @@ int ObDasAsyncRpcCallBackContext::init(const ObMemAttr &attr) int ObDASSyncFetchP::process() { int ret = OB_SUCCESS; - NG_TRACE(fetch_das_result_process_begin); FLTSpanGuard(fetch_das_result_process); ObDASDataFetchReq &req = arg_; ObDASDataFetchRes &res = result_; @@ -300,7 +295,6 @@ int ObDASSyncFetchP::process() } else { res.set_has_more(has_more); } - NG_TRACE(fetch_das_result_process_end); return ret; } diff --git a/src/sql/das/ob_data_access_service.cpp b/src/sql/das/ob_data_access_service.cpp index 52ac233a1..e33a56208 100644 --- a/src/sql/das/ob_data_access_service.cpp +++ b/src/sql/das/ob_data_access_service.cpp @@ -86,7 +86,6 @@ int ObDataAccessService::execute_das_task( int ret = OB_SUCCESS; if (OB_LIKELY(das_ref.is_execute_directly())) { common::ObSEArray task_wrapper; - NG_TRACE(do_local_das_task_begin); FLTSpanGuard(do_local_das_task); while (OB_SUCC(ret) && OB_SUCC(task_ops.get_aggregated_tasks(task_wrapper)) && task_wrapper.count() != 0) { @@ -105,7 +104,6 @@ int ObDataAccessService::execute_das_task( } task_wrapper.reuse(); } - NG_TRACE(do_local_das_task_end); } else if (OB_FAIL(execute_dist_das_task(das_ref, task_ops, async))) { LOG_WARN("failed to execute dist das task", K(ret)); } @@ -115,7 +113,6 @@ int ObDataAccessService::execute_das_task( int ObDataAccessService::get_das_task_id(int64_t &das_id) { int ret = OB_SUCCESS; - NG_TRACE(get_das_id_begin); FLTSpanGuard(get_das_id); const int MAX_RETRY_TIMES = 50; int64_t tmp_das_id = 0; @@ -143,7 +140,6 @@ int ObDataAccessService::get_das_task_id(int64_t &das_id) if (OB_SUCC(ret)) { das_id = tmp_das_id; } - NG_TRACE(get_das_id_end); return ret; } @@ -313,7 +309,6 @@ int ObDataAccessService::end_das_task(ObDASRef &das_ref, ObIDASTaskOp &task_op) int ObDataAccessService::rescan_das_task(ObDASRef &das_ref, ObDASScanOp &scan_op) { int ret = OB_SUCCESS; - NG_TRACE(rescan_das_task_begin); FLTSpanGuard(rescan_das_task); ObArenaAllocator tmp_alloc; @@ -338,7 +333,6 @@ int ObDataAccessService::rescan_das_task(ObDASRef &das_ref, ObDASScanOp &scan_op LOG_WARN("failed to retry das task", K(tmp_ret)); } } - NG_TRACE(rescan_das_task_end); return ret; } @@ -346,7 +340,6 @@ int ObDataAccessService::do_local_das_task(ObDASRef &das_ref, ObDASTaskArg &task_arg) { UNUSED(das_ref); int ret = OB_SUCCESS; - NG_TRACE(do_local_das_task_begin); FLTSpanGuard(do_local_das_task); const common::ObSEArray &task_ops = task_arg.get_task_ops(); @@ -365,7 +358,6 @@ int ObDataAccessService::do_local_das_task(ObDASRef &das_ref, } } } - NG_TRACE(do_local_das_task_end); return ret; } @@ -374,7 +366,6 @@ int ObDataAccessService::do_async_remote_das_task( ObDASTaskArg &task_arg) { int ret = OB_SUCCESS; void *resp_buf = nullptr; - NG_TRACE(do_async_remote_das_task_begin); FLTSpanGuard(do_async_remote_das_task); ObSQLSessionInfo *session = das_ref.get_exec_ctx().get_my_session(); ObPhysicalPlanCtx *plan_ctx = das_ref.get_exec_ctx().get_physical_plan_ctx(); @@ -463,7 +454,6 @@ int ObDataAccessService::do_async_remote_das_task( } } } - NG_TRACE_EXT(do_async_remote_das_task_end, OB_Y(ret), OB_ID(addr), task_arg.get_runner_svr()); return ret; } @@ -472,7 +462,6 @@ int ObDataAccessService::do_sync_remote_das_task( ObDASTaskArg &task_arg) { int ret = OB_SUCCESS; void *resp_buf = nullptr; - NG_TRACE(do_sync_remote_das_task_begin); FLTSpanGuard(do_sync_remote_das_task); ObSQLSessionInfo *session = das_ref.get_exec_ctx().get_my_session(); ObPhysicalPlanCtx *plan_ctx = das_ref.get_exec_ctx().get_physical_plan_ctx(); @@ -555,7 +544,6 @@ int ObDataAccessService::do_sync_remote_das_task( } } das_ref.inc_concurrency_limit(); - NG_TRACE_EXT(do_sync_remote_das_task_end, OB_Y(ret), OB_ID(addr), task_arg.get_runner_svr()); return ret; } diff --git a/src/sql/ob_sql.cpp b/src/sql/ob_sql.cpp index 368e522eb..c553ce09e 100644 --- a/src/sql/ob_sql.cpp +++ b/src/sql/ob_sql.cpp @@ -3249,7 +3249,6 @@ int ObSql::optimize_stmt( FLTSpanGuard(optimize); logical_plan = NULL; LOG_TRACE("stmt to generate plan", K(stmt)); - NG_TRACE(optimize_begin); OPT_TRACE_TITLE("START GENERATE PLAN"); if (OB_FAIL(optimizer.optimize(stmt, logical_plan))) { LOG_WARN("Failed to optimize logical plan", K(ret));