From 3b95f3b6d01185d9b3cefdbcf0d05db3d493f68e Mon Sep 17 00:00:00 2001 From: morningman Date: Tue, 18 Mar 2025 17:23:49 +0800 Subject: [PATCH] [fix](webui) add connection context to avoid NPE --- .../java/org/apache/doris/httpv2/util/StatementSubmitter.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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);