From 7cda1ea330680e3b32b7985dc7c7cf7ab98f9e52 Mon Sep 17 00:00:00 2001
From: liucc1997 <1192520566@qq.com>
Date: Wed, 27 Dec 2023 04:48:57 +0000
Subject: [PATCH] [CP] reset get_sql_arena_allocator() after rpc callback
 finished

---
 deps/oblib/src/rpc/frame/ob_req_transport.cpp | 1 +
 deps/oblib/src/rpc/obrpc/ob_poc_rpc_proxy.cpp | 1 +
 2 files changed, 2 insertions(+)

diff --git a/deps/oblib/src/rpc/frame/ob_req_transport.cpp b/deps/oblib/src/rpc/frame/ob_req_transport.cpp
index 718c7838f6..9f0cdbc215 100644
--- a/deps/oblib/src/rpc/frame/ob_req_transport.cpp
+++ b/deps/oblib/src/rpc/frame/ob_req_transport.cpp
@@ -144,6 +144,7 @@ int async_cb(easy_request_t *r)
   if (!OB_SUCC(ret)) {
     LOG_WARN("process async request fail", K(r), K(ret), K(pcode));
   }
+  THIS_WORKER.get_sql_arena_allocator().reset();
 
   const int64_t cur_time = ObTimeUtility::current_time();
   const int64_t total_time = cur_time  - start_time;
diff --git a/deps/oblib/src/rpc/obrpc/ob_poc_rpc_proxy.cpp b/deps/oblib/src/rpc/obrpc/ob_poc_rpc_proxy.cpp
index 8a2d66d6d1..115a19b82b 100644
--- a/deps/oblib/src/rpc/obrpc/ob_poc_rpc_proxy.cpp
+++ b/deps/oblib/src/rpc/obrpc/ob_poc_rpc_proxy.cpp
@@ -157,6 +157,7 @@ int ObAsyncRespCallback::handle_resp(int io_err, const char* buf, int64_t sz)
   }
   pool_.destroy();
   ObCurTraceId::reset();
+  THIS_WORKER.get_sql_arena_allocator().reset();
   const int64_t cur_time = ObTimeUtility::current_time();
   const int64_t total_time = cur_time  - start_time;
   const int64_t decode_time = after_decode_time - start_time;