diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSessionsManager.java b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSessionsManager.java
index 9c3871af5d301b..2c3a5258cc4612 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSessionsManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSessionsManager.java
@@ -49,8 +49,6 @@ static ConnectContext buildConnectContext(String peerIdentity, UserIdentity user
         ConnectContext connectContext = new FlightSqlConnectContext(peerIdentity);
         connectContext.setEnv(Env.getCurrentEnv());
         connectContext.setStartTime();
-        connectContext.getSessionVariable().setEnablePipelineEngine(false); // TODO
-        connectContext.getSessionVariable().setEnablePipelineXEngine(false); // TODO
         connectContext.setQualifiedUser(userIdentity.getQualifiedUser());
         connectContext.setCurrentUserIdentity(userIdentity);
         connectContext.setRemoteIP(remoteIP);