diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
index eef50cbdb12046f..090afc587c5bdbd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
@@ -94,6 +94,7 @@
 import org.apache.doris.qe.QueryState;
 import org.apache.doris.qe.StmtExecutor;
 import org.apache.doris.qe.VariableMgr;
+import org.apache.doris.service.arrowflight.FlightSQLConnectProcessor;
 import org.apache.doris.statistics.ColumnStatistic;
 import org.apache.doris.statistics.ResultRow;
 import org.apache.doris.statistics.StatisticsCacheKey;
@@ -1073,9 +1074,12 @@ public TMasterOpResult forward(TMasterOpRequest params) throws TException {
         if (context.getConnectType().equals(ConnectType.MYSQL)) {
             processor = new MysqlConnectProcessor(context);
         } else if (context.getConnectType().equals(ConnectType.ARROW_FLIGHT_SQL)) {
-            processor = new ArrowFlightSQLConnectProcessor(context);
+            processor = new FlightSQLConnectProcessor(context);
+        } else {
+            LOG.warn("unknown ConnectType: {}", context.getConnectType());
         }
 
+        assert processor != null;
         TMasterOpResult result = processor.proxyExecute(params);
         if (QueryState.MysqlStateType.ERR.name().equalsIgnoreCase(result.getStatus())) {
             context.getState().setError(result.getStatus());