diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index 458202ced4..3ab3d40dc7 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -1824,7 +1824,7 @@ public class Coordinator implements CoordInterface { throw new UserException(SystemInfoService.NO_BACKEND_LOAD_AVAILABLE_MSG); } if (backend.getArrowFlightSqlPort() < 0) { - return null; + throw new UserException("be arrow_flight_sql_port cannot be empty."); } return backend.getArrowFlightAddress(); }