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 32d055069a..6c61c9cdd4 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();