diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/util/HttpURLUtil.java b/fe/fe-core/src/main/java/org/apache/doris/common/util/HttpURLUtil.java index a5394d6d48e28f..966bc6c66e5363 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/util/HttpURLUtil.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/HttpURLUtil.java @@ -31,7 +31,9 @@ public class HttpURLUtil { public static HttpURLConnection getConnectionWithNodeIdent(String request) throws IOException { URL url = new URL(request); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); - HostInfo selfNode = Env.getCurrentEnv().getSelfNode(); + // Must use Env.getServingEnv() instead of getCurrentEnv(), + // because here we need to obtain selfNode through the official service catalog. + HostInfo selfNode = Env.getServingEnv().getSelfNode(); conn.setRequestProperty(Env.CLIENT_NODE_HOST_KEY, selfNode.getHost()); conn.setRequestProperty(Env.CLIENT_NODE_PORT_KEY, selfNode.getPort() + ""); return conn; diff --git a/fe/fe-core/src/main/java/org/apache/doris/httpv2/meta/MetaService.java b/fe/fe-core/src/main/java/org/apache/doris/httpv2/meta/MetaService.java index 6deea9f0e425cf..cc0cb47a637c9e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/httpv2/meta/MetaService.java +++ b/fe/fe-core/src/main/java/org/apache/doris/httpv2/meta/MetaService.java @@ -71,7 +71,7 @@ private boolean isFromValidFe(HttpServletRequest request) { Frontend fe = Env.getCurrentEnv().checkFeExist(clientHost, clientPort); if (fe == null) { - LOG.warn("request is not from valid FE. client: {}", clientHost); + LOG.warn("request is not from valid FE. client: {}, {}", clientHost, clientPortStr); return false; } return true;