From 9c7663609ed9ca3413431c4e2bdcec6c9a973c27 Mon Sep 17 00:00:00 2001
From: obdev <obdev@oceanbase.com>
Date: Mon, 12 Jul 2021 17:14:00 +0800
Subject: [PATCH] add guard_lock for deserialize session_info

---
 src/sql/executor/ob_task.cpp | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/sql/executor/ob_task.cpp b/src/sql/executor/ob_task.cpp
index d87c7a9df8..411e33f651 100644
--- a/src/sql/executor/ob_task.cpp
+++ b/src/sql/executor/ob_task.cpp
@@ -681,6 +681,8 @@ OB_DEF_DESERIALIZE(ObRemoteTask)
       LOG_WARN("create my session failed", K(ret), K(tenant_id));
     } else {
       session_info_ = exec_ctx_->get_my_session();
+      ObSQLSessionInfo::LockGuard query_guard(session_info_->get_query_lock());
+      ObSQLSessionInfo::LockGuard data_guard(session_info_->get_thread_data_lock());
       OB_UNIS_DECODE(*session_info_);
       OB_UNIS_DECODE(remote_sql_info_->is_batched_stmt_);
     }
-- 
GitLab