7

xinyiZzz · Nov 3, 2024 · 0e0f5ad · 0e0f5ad
1 parent 9e92241
commit 0e0f5ad
Showing 1 changed file with 3 additions and 4 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
@@ -27,7 +27,6 @@
 import org.apache.doris.qe.QueryState.MysqlStateType;
 import org.apache.doris.service.arrowflight.results.FlightSqlResultCacheEntry;
 import org.apache.doris.service.arrowflight.sessions.FlightSessionsManager;
-import org.apache.doris.thrift.TNetworkAddress;
 
 import com.google.common.base.Preconditions;
 import com.google.protobuf.Any;
@@ -249,9 +248,9 @@ private FlightInfo executeQueryStatement(String peerIdentity, ConnectContext con
                     Ticket ticket = new Ticket(Any.pack(ticketStatement).toByteArray());
                     // TODO Support multiple endpoints.
                     Location location;
-                    TNetworkAddress publicAccessAddr = flightSQLConnectProcessor.getPublicAccessAddr();
-                    if (publicAccessAddr.isSetHostname()) {
-                        location = Location.forGrpcInsecure(publicAccessAddr.hostname, publicAccessAddr.port);
+                    if (flightSQLConnectProcessor.getPublicAccessAddr().isSetHostname()) {
+                        location = Location.forGrpcInsecure(flightSQLConnectProcessor.getPublicAccessAddr().hostname,
+                                flightSQLConnectProcessor.getPublicAccessAddr().port);
                     } else {
                         location = Location.forGrpcInsecure(remoteResultAddrHostName, remoteResultAddrPort);
                     }