diff --git a/src/observer/mysql/obmp_query.cpp b/src/observer/mysql/obmp_query.cpp
index e64a54fc0..d81ee2701 100644
--- a/src/observer/mysql/obmp_query.cpp
+++ b/src/observer/mysql/obmp_query.cpp
@@ -714,6 +714,7 @@ OB_INLINE int ObMPQuery::do_process(ObSQLSessionInfo &session,
     } else {
       session.set_current_execution_id(GCTX.sql_engine_->get_execution_id());
       session.reset_plsql_exec_time();
+      session.set_stmt_type(stmt::T_NONE);
       result.get_exec_context().set_need_disconnect(true);
       ctx_.schema_guard_ = schema_guard;
       retry_ctrl_.set_tenant_local_schema_version(tenant_version);
diff --git a/src/sql/resolver/ob_resolver_utils.cpp b/src/sql/resolver/ob_resolver_utils.cpp
index af5321d67..c95541a2e 100644
--- a/src/sql/resolver/ob_resolver_utils.cpp
+++ b/src/sql/resolver/ob_resolver_utils.cpp
@@ -2436,7 +2436,8 @@ stmt::StmtType ObResolverUtils::get_stmt_type_by_item_type(const ObItemType item
         type = stmt::T_INSERT;
       }
       break;
-      case T_SP_CREATE_TYPE: {
+      case T_SP_CREATE_TYPE:
+      case T_SP_CREATE_TYPE_BODY: {
         type = stmt::T_CREATE_TYPE;
       }
       break;