diff --git a/src/observer/omt/ob_th_worker.h b/src/observer/omt/ob_th_worker.h index b219d4b14043b88f1e64000b28beae832b6fb11a..6b77c558b0088c005a3fd7d2953a436a3ccde9d5 100644 --- a/src/observer/omt/ob_th_worker.h +++ b/src/observer/omt/ob_th_worker.h @@ -19,6 +19,7 @@ #include "lib/coro/co.h" #include "rpc/ob_request.h" #include "lib/coro/co_user_thread.h" +#include "lib/thread/ob_thread_name.h" namespace oceanbase { @@ -184,6 +185,7 @@ inline void ObThWorker::reset() ws_ = WStatus::STOPPED; active_ = false; unset_tidx(); + lib::set_thread_name("OMT_FREE", ObWorker::get_tidx()); } inline void ObThWorker::set_tenant(ObTenant* tenant)