diff --git a/src/sql/engine/prepare/ob_deallocate_executor.cpp b/src/sql/engine/prepare/ob_deallocate_executor.cpp index d0d77d0f55c7884c24d6c5bacb75f872c6e96e09..113291a14ab3f74a7ccfcf17554051c926fe070d 100644 --- a/src/sql/engine/prepare/ob_deallocate_executor.cpp +++ b/src/sql/engine/prepare/ob_deallocate_executor.cpp @@ -29,8 +29,8 @@ int ObDeallocateExecutor::execute(ObExecContext& ctx, ObDeallocateStmt& stmt) } else { if (OB_FAIL(ctx.get_my_session()->remove_prepare(stmt.get_prepare_name()))) { LOG_WARN("failed to remove prepare", K(stmt.get_prepare_name()), K(ret)); - } else if (OB_FAIL(ctx.get_my_session()->remove_ps_session_info(stmt.get_prepare_id()))) { - LOG_WARN("failed to remove prepare", K(stmt.get_prepare_id()), K(ret)); + } else if (OB_FAIL(ctx.get_my_session()->close_ps_stmt(stmt.get_prepare_id()))) { + LOG_WARN("fail to deallocate ps stmt", K(ret), K(stmt.get_prepare_id())); } else { /*do nothing*/ } }