diff --git a/src/observer/mysql/ob_mysql_request_manager.cpp b/src/observer/mysql/ob_mysql_request_manager.cpp index eaf16b965ec745238d5c33d42d77d38826326b02..86e3b0d71f675b5796b76dd79c2440e70d909db7 100644 --- a/src/observer/mysql/ob_mysql_request_manager.cpp +++ b/src/observer/mysql/ob_mysql_request_manager.cpp @@ -30,6 +30,7 @@ #include "sql/plan_cache/ob_plan_cache_callback.h" #include "sql/plan_cache/ob_plan_cache_value.h" #include "sql/session/ob_basic_session_info.h" +#include "observer/mysql/ob_query_response_time.h" namespace oceanbase { using namespace oceanbase::share::schema; @@ -198,6 +199,9 @@ int ObMySQLRequestManager::record_request(const ObAuditRecordData& audit_record, audit_record.exec_timestamp_.receive_ts_); } + // query response time + observer::ObRSTCollector::get_instance().collect_query_response_time(audit_record.tenant_id_,audit_record.get_elapsed_time()); + // push into queue if (OB_SUCC(ret)) { int64_t req_id = 0; diff --git a/src/sql/monitor/ob_exec_stat.h b/src/sql/monitor/ob_exec_stat.h index 2ece991853160fc7d5b29f788da40436ddb39c69..26e0c3c9404a1972c6162d6d44b85a5ed382f327 100644 --- a/src/sql/monitor/ob_exec_stat.h +++ b/src/sql/monitor/ob_exec_stat.h @@ -57,7 +57,6 @@ EVENT_INFO(FUSE_ROW_CACHE_MISS, fuse_row_cache_miss) #include "sql/ob_sql_define.h" #include "sql/plan_cache/ob_plan_cache_util.h" #include "observer/virtual_table/ob_information_query_response_time.h" -#include "observer/mysql/ob_query_response_time.h" namespace oceanbase { namespace sql { struct ObExecRecord { @@ -343,7 +342,6 @@ struct ObAuditRecordData { EVENT_ADD(SYS_TIME_MODEL_DB_TIME, elapsed_time); EVENT_ADD(SYS_TIME_MODEL_DB_CPU, cpu_time); } - observer::ObRSTCollector::get_instance().collect_query_response_time(tenant_id_,elapsed_time); } bool is_timeout() const