7

xinyiZzz · Nov 3, 2024 · 4a07017 · 4a07017
1 parent 0e0f5ad
commit 4a07017
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -248,7 +248,7 @@ private FlightInfo executeQueryStatement(String peerIdentity, ConnectContext con
                     Ticket ticket = new Ticket(Any.pack(ticketStatement).toByteArray());
                     // TODO Support multiple endpoints.
                     Location location;
-                    if (flightSQLConnectProcessor.getPublicAccessAddr().isSetHostname()) {
+                    if (flightSQLConnectProcessor.getPublicAccessAddr() == null) {
                         location = Location.forGrpcInsecure(flightSQLConnectProcessor.getPublicAccessAddr().hostname,
                                 flightSQLConnectProcessor.getPublicAccessAddr().port);
                     } else {