This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 5db2c8b8bc1 [branch-2.1](arrow-flight-sql) Fix return result from FE
Arrow Flight server error 0.0.0.0:xxx, connection refused (#40229)
5db2c8b8bc1 is described below
commit 5db2c8b8bc1ed19adfa80c37cafd0814626285a0
Author: Xinyi Zou <[email protected]>
AuthorDate: Mon Sep 2 09:45:27 2024 +0800
[branch-2.1](arrow-flight-sql) Fix return result from FE Arrow Flight
server error 0.0.0.0:xxx, connection refused (#40229)
pick #40002
---
.../apache/doris/service/arrowflight/DorisFlightSqlService.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
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 df9099c6816..b83936dab3b 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 class DorisFlightSqlService {
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: {}",
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
