hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

Fix core at result set destructor

Browse Source
This commit is contained in:
obdev
2024-04-09 05:26:35 +00:00
committed by ob-robot
parent 0938dda055
commit 8addb38f3e
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/prepare/ob_execute_executor.cpp
View File

@ -58,6 +58,7 @@ int ObExecuteExecutor::execute(ObExecContext &ctx, ObExecuteStmt &stmt)
} }
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
ObSqlCtx sql_ctx;
SMART_VAR(ObResultSet, result_set, *ctx.get_my_session(), ctx.get_allocator()) { SMART_VAR(ObResultSet, result_set, *ctx.get_my_session(), ctx.get_allocator()) {
result_set.set_ps_protocol(); result_set.set_ps_protocol();
ObTaskExecutorCtx *task_ctx = result_set.get_exec_context().get_task_executor_ctx(); ObTaskExecutorCtx *task_ctx = result_set.get_exec_context().get_task_executor_ctx();
@ -73,7 +74,6 @@ int ObExecuteExecutor::execute(ObExecContext &ctx, ObExecuteStmt &stmt)
OB_SYS_TENANT_ID, sys_version))) { OB_SYS_TENANT_ID, sys_version))) {
LOG_WARN("fail get sys schema version", K(ret)); LOG_WARN("fail get sys schema version", K(ret));
} else { } else {
ObSqlCtx sql_ctx;
sql_ctx.retry_times_ = 0; sql_ctx.retry_times_ = 0;
sql_ctx.session_info_ = ctx.get_my_session(); sql_ctx.session_info_ = ctx.get_my_session();
sql_ctx.disable_privilege_check_ = true; sql_ctx.disable_privilege_check_ = true;