[master] let connection_id() return master session id

2023-06-28 03:42:23 +00:00
parent 3162299290
commit 7a49e4861d
1 changed files with 2 additions and 1 deletions
--- 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;
 }