diff --git a/fe/fe-core/src/main/java/org/apache/doris/httpv2/util/StatementSubmitter.java b/fe/fe-core/src/main/java/org/apache/doris/httpv2/util/StatementSubmitter.java
index 2c9ef15bda0a0d..60144df2c0eada 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/httpv2/util/StatementSubmitter.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/httpv2/util/StatementSubmitter.java
@@ -31,7 +31,9 @@
 import org.apache.doris.common.util.SqlParserUtils;
 import org.apache.doris.httpv2.util.streamresponse.JsonStreamResponse;
 import org.apache.doris.httpv2.util.streamresponse.StreamResponseInf;
+import org.apache.doris.qe.AutoCloseConnectContext;
 import org.apache.doris.qe.ConnectContext;
+import org.apache.doris.statistics.util.StatisticsUtil;
 
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
@@ -250,7 +252,7 @@ private ExecutionResultSet generateExecStatus(long startTime) {
 
     public static StatementBase analyzeStmt(String stmtStr) throws Exception {
         SqlParser parser = new SqlParser(new SqlScanner(new StringReader(stmtStr)));
-        try {
+        try (AutoCloseConnectContext a = StatisticsUtil.buildConnectContext(false)) {
             return SqlParserUtils.getFirstStmt(parser);
         } catch (AnalysisException e) {
             String errorMessage = parser.getErrorMsg(stmtStr);