diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlService.java b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlService.java index df9099c6816080..b83936dab3bdc6 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlService.java +++ b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/DorisFlightSqlService.java @@ -18,6 +18,7 @@ package org.apache.doris.service.arrowflight; import org.apache.doris.common.Config; +import org.apache.doris.service.FrontendOptions; import org.apache.doris.service.arrowflight.auth2.FlightBearerTokenAuthenticator; import org.apache.doris.service.arrowflight.sessions.FlightSessionsManager; import org.apache.doris.service.arrowflight.sessions.FlightSessionsWithTokenManager; @@ -45,7 +46,6 @@ public class DorisFlightSqlService { public DorisFlightSqlService(int port) { BufferAllocator allocator = new RootAllocator(); - Location location = Location.forGrpcInsecure("0.0.0.0", port); // arrow_flight_token_cache_size less than qe_max_connection to avoid `Reach limit of connections`. // arrow flight sql is a stateless protocol, connection is usually not actively disconnected. // bearer token is evict from the cache will unregister ConnectContext. @@ -54,8 +54,9 @@ public DorisFlightSqlService(int port) { Config.arrow_flight_token_alive_time); this.flightSessionsManager = new FlightSessionsWithTokenManager(flightTokenManager); - DorisFlightSqlProducer producer = new DorisFlightSqlProducer(location, flightSessionsManager); - flightServer = FlightServer.builder(allocator, location, producer) + DorisFlightSqlProducer producer = new DorisFlightSqlProducer( + Location.forGrpcInsecure(FrontendOptions.getLocalHostAddress(), port), flightSessionsManager); + flightServer = FlightServer.builder(allocator, Location.forGrpcInsecure("0.0.0.0", port), producer) .headerAuthenticator(new FlightBearerTokenAuthenticator(flightTokenManager)).build(); LOG.info("Arrow Flight SQL service is created, port: {}, token_cache_size: {}" + ", qe_max_connection: {}, token_alive_time: {}",