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");