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 76f6a63b71a672..884f7988aeaa6a 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;
@@ -221,7 +223,7 @@ private ExecutionResultSet generateExecStatus(long startTime) {
 
         private 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);