This is an automated email from the ASF dual-hosted git repository.

wuzhiguo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/bigtop-manager.git


The following commit(s) were added to refs/heads/main by this push:
     new 267359c9 BIGTOP-4501: NodeManager should find the ResourceManager IP 
address when starting (#272)
267359c9 is described below

commit 267359c930975c79f94d816774cdda6167a5d4ee
Author: Chenhuab <[email protected]>
AuthorDate: Fri Sep 26 14:51:58 2025 +0800

    BIGTOP-4501: NodeManager should find the ResourceManager IP address when 
starting (#272)
---
 .../stack/bigtop/v3_3_0/hadoop/HadoopParams.java   | 24 ++++++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git 
a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java
 
b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java
index cbfb5684..22c27739 100644
--- 
a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java
+++ 
b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hadoop/HadoopParams.java
@@ -155,6 +155,30 @@ public class HadoopParams extends BigtopParams {
         List<String> resourcemanagerList = 
LocalSettings.componentHosts("resourcemanager");
         if (!resourcemanagerList.isEmpty()) {
             yarnSite.put("yarn.resourcemanager.hostname", 
MessageFormat.format("{0}", resourcemanagerList.get(0)));
+            yarnSite.put(
+                    "yarn.resourcemanager.resource-tracker.address",
+                    ((String) 
yarnSite.get("yarn.resourcemanager.resource-tracker.address"))
+                            .replace("0.0.0.0", resourcemanagerList.get(0)));
+            yarnSite.put(
+                    "yarn.resourcemanager.scheduler.address",
+                    ((String) 
yarnSite.get("yarn.resourcemanager.scheduler.address"))
+                            .replace("0.0.0.0", resourcemanagerList.get(0)));
+            yarnSite.put(
+                    "yarn.resourcemanager.address",
+                    ((String) yarnSite.get("yarn.resourcemanager.address"))
+                            .replace("0.0.0.0", resourcemanagerList.get(0)));
+            yarnSite.put(
+                    "yarn.resourcemanager.admin.address",
+                    ((String) 
yarnSite.get("yarn.resourcemanager.admin.address"))
+                            .replace("0.0.0.0", resourcemanagerList.get(0)));
+            yarnSite.put(
+                    "yarn.resourcemanager.webapp.address",
+                    ((String) 
yarnSite.get("yarn.resourcemanager.webapp.address"))
+                            .replace("0.0.0.0", resourcemanagerList.get(0)));
+            yarnSite.put(
+                    "yarn.resourcemanager.webapp.https.address",
+                    ((String) 
yarnSite.get("yarn.resourcemanager.webapp.https.address"))
+                            .replace("0.0.0.0", resourcemanagerList.get(0)));
         }
 
         nodeManagerLogDir = (String) yarnSite.get("yarn.nodemanager.log-dirs");

Reply via email to