12

xinyiZzz · Nov 1, 2023 · c3d2d58 · c3d2d58
1 parent c16d42e
commit c3d2d58
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlProducer.java b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlProducer.java
@@ -20,7 +20,6 @@
 
 package org.apache.doris.service.arrowflight;
 
-import org.apache.doris.common.exception.InternalException;
 import org.apache.doris.common.util.DebugUtil;
 import org.apache.doris.common.util.Util;
 import org.apache.doris.mysql.MysqlCommand;
@@ -143,7 +142,7 @@ public FlightInfo getFlightInfoStatement(final CommandStatementQuery request, fi
 
             flightSQLConnectProcessor.handleQuery(query);
             if (connectContext.getState().getStateType() == MysqlStateType.ERR) {
-                throw new InternalException("after handleQuery");
+                throw new RuntimeException("after handleQuery");
             }
             if (connectContext.getFlightSqlChannel().resultNum() == 0) {
                 String queryId = UUID.randomUUID().toString();