diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index dce35a218dee72e..deb10b4e0a2faf3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -187,7 +187,6 @@
 import java.io.IOException;
 import java.io.StringReader;
 import java.nio.ByteBuffer;
-import java.sql.Statement;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
@@ -2670,7 +2669,7 @@ public void executeArrowFlightQuery(FlightStatementContext flightStatementContex
                 coord.exec();
             } catch (Exception e) {
                 queryScheduleSpan.recordException(e);
-                LOG.warn("Failed to coord exec, because: {}", e.getMessage(), e);
+                LOG.warn("Failed to coord exec Arrow Flight SQL, because: {}", e.getMessage(), e);
                 throw new InternalQueryExecutionException(e.getMessage() + Util.getRootCauseMessage(e), e);
             } finally {
                 queryScheduleSpan.end();
diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightStatementContext.java b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightStatementContext.java
index 86f335d22585cd7..1e28cd173ec2264 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightStatementContext.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightStatementContext.java
@@ -23,6 +23,7 @@
 import org.apache.doris.common.Status;
 import org.apache.doris.common.util.DebugUtil;
 import org.apache.doris.common.util.Util;
+import org.apache.doris.proto.InternalService;
 import org.apache.doris.proto.Types;
 import org.apache.doris.qe.AutoCloseConnectContext;
 import org.apache.doris.qe.ConnectContext;
@@ -132,7 +133,6 @@ public static AutoCloseConnectContext buildConnectContext() {
         ConnectContext connectContext = new ConnectContext();
         SessionVariable sessionVariable = connectContext.getSessionVariable();
         sessionVariable.internalSession = true;
-        sessionVariable.setEnableNereidsPlanner(false); // TODO
         sessionVariable.setEnablePipelineEngine(false); // TODO
         sessionVariable.setEnablePipelineXEngine(false); // TODO
         connectContext.setEnv(Env.getCurrentEnv());