This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new a1d0741651e [fix](feservice) remove connect context (#33583)
a1d0741651e is described below
commit a1d0741651eaa499682d1712eeadeeeef1d68fc9
Author: meiyi <[email protected]>
AuthorDate: Fri Apr 12 23:16:33 2024 +0800
[fix](feservice) remove connect context (#33583)
---
fe/fe-core/src/main/java/org/apache/doris/service/FeServer.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/FeServer.java
b/fe/fe-core/src/main/java/org/apache/doris/service/FeServer.java
index 32d055069a2..6c61c9cdd48 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/FeServer.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/FeServer.java
@@ -19,6 +19,7 @@ package org.apache.doris.service;
import org.apache.doris.common.ThriftServer;
import org.apache.doris.metric.MetricRepo;
+import org.apache.doris.qe.ConnectContext;
import org.apache.doris.thrift.FrontendService;
import org.apache.logging.log4j.LogManager;
@@ -62,6 +63,7 @@ public class FeServer {
// If exception occurs, do not deal it, just keep as
the previous
throw t;
} finally {
+ ConnectContext.remove();
feServiceLogger.debug("finish process request for {}",
name);
if (MetricRepo.isInit) {
long end = System.currentTimeMillis();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
