diff --git a/src/sql/engine/expr/ob_expr_connection_id.cpp b/src/sql/engine/expr/ob_expr_connection_id.cpp
index 1286029ba8..610861cbc1 100644
--- a/src/sql/engine/expr/ob_expr_connection_id.cpp
+++ b/src/sql/engine/expr/ob_expr_connection_id.cpp
@@ -51,7 +51,8 @@ int ObExprConnectionId::eval_connection_id(const ObExpr &expr, ObEvalCtx &ctx,
     ret = OB_ERR_UNEXPECTED;
     LOG_WARN("session info is null", K(ret));
   } else {
-    expr_datum.set_uint32(session_info->get_sessid());
+    auto sid = session_info->is_master_session() ? session_info->get_sessid() : session_info->get_master_sessid();
+    expr_datum.set_uint32(sid);
   }
   return ret;
 }