From 4a07017f3148507a4adb1698e22053f6740f3647 Mon Sep 17 00:00:00 2001 From: Xinyi Zou Date: Sun, 3 Nov 2024 22:29:20 +0800 Subject: [PATCH] 7 --- .../doris/service/arrowflight/DorisFlightSqlProducer.java | 2 +- 1 file changed, 1 insertion(+), 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 index 3a5e86b2b2c94c0..0c18f3585dbe197 100644 --- 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 {