3

xinyiZzz · Nov 19, 2024 · 3a9e2a8 · 3a9e2a8
1 parent ba527ca
commit 3a9e2a8
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -734,7 +734,6 @@ protected void execInternal() throws Exception {
                 enableParallelResultSink = queryOptions.isEnableParallelOutfile();
             }
 
-            TNetworkAddress execBeAddr = topParams.instanceExecParams.get(0).host;
             Set<TNetworkAddress> addrs = new HashSet<>();
             for (FInstanceExecParam param : topParams.instanceExecParams) {
                 if (addrs.contains(param.host)) {
@@ -754,7 +753,7 @@ protected void execInternal() throws Exception {
                         finstId = topParams.instanceExecParams.get(0).instanceId;
                     }
                     context.addFlightSqlEndpointsLocation(new FlightSqlEndpointsLocation(finstId,
-                            toArrowFlightHost(execBeAddr), toBrpcHost(execBeAddr), fragments.get(0).getOutputExprs()));
+                            toArrowFlightHost(param.host), toBrpcHost(param.host), fragments.get(0).getOutputExprs()));
                 }
             }
 
@@ -766,7 +765,8 @@ protected void execInternal() throws Exception {
                 // set the broker address for OUTFILE sink
                 ResultFileSink topResultFileSink = (ResultFileSink) topDataSink;
                 FsBroker broker = Env.getCurrentEnv().getBrokerMgr()
-                        .getBroker(topResultFileSink.getBrokerName(), execBeAddr.getHostname());
+                        .getBroker(topResultFileSink.getBrokerName(),
+                                topParams.instanceExecParams.get(0).host.getHostname());
                 topResultFileSink.setBrokerAddr(broker.host, broker.port);
             }
         } else {