fix hadoop

apache · Sep 11, 2024 · 3729c08 · 3729c08
1 parent 96c4e27
commit 3729c08
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 5 deletions.
diff --git a/...er-server/src/main/java/org/apache/bigtop/manager/server/service/impl/JobServiceImpl.java b/...er-server/src/main/java/org/apache/bigtop/manager/server/service/impl/JobServiceImpl.java
@@ -79,7 +79,8 @@ public PageVO<JobVO> list(Long clusterId) {
             jobPOList = jobDao.findAllByClusterId(clusterId);
         }
         PageInfo<JobPO> pageInfo = new PageInfo<>(jobPOList);
-        List<JobPO> allByIdsJoin = jobDao.findAllByIdsJoin(jobPOList.stream().map(JobPO::getId).toList());
+        List<JobPO> allByIdsJoin =
+                jobDao.findAllByIdsJoin(jobPOList.stream().map(JobPO::getId).toList());
         pageInfo.setList(allByIdsJoin);
 
         return PageVO.of(pageInfo);

diff --git a/...k-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hdfs/HdfsParams.java b/...k-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hdfs/HdfsParams.java
@@ -85,7 +85,8 @@ public Map<String, Object> coreSite() {
         Map<String, Object> coreSite = LocalSettings.configurations(serviceName(), "core-site");
         List<String> namenodeList = LocalSettings.hosts("namenode");
         if (!namenodeList.isEmpty()) {
-            coreSite.put("fs.defaultFS", ((String) coreSite.get("fs.defaultFS")).replace("localhost", namenodeList.get(0)));
+            coreSite.put(
+                    "fs.defaultFS", ((String) coreSite.get("fs.defaultFS")).replace("localhost", namenodeList.get(0)));
         }
         return coreSite;
     }
@@ -100,9 +101,15 @@ public Map<String, Object> hdfsSite() {
         Map<String, Object> hdfsSite = LocalSettings.configurations(serviceName(), "hdfs-site");
         List<String> namenodeList = LocalSettings.hosts("namenode");
         if (!namenodeList.isEmpty()) {
-            hdfsSite.put("dfs.namenode.rpc-address", ((String) hdfsSite.get("dfs.namenode.rpc-address")).replace("0.0.0.0", namenodeList.get(0)));
-            hdfsSite.put("dfs.datanode.https.address", ((String) hdfsSite.get("dfs.datanode.https.address")).replace("0.0.0.0", namenodeList.get(0)));
-            hdfsSite.put("dfs.namenode.https-address", ((String) hdfsSite.get("dfs.namenode.https-address")).replace("0.0.0.0", namenodeList.get(0)));
+            hdfsSite.put(
+                    "dfs.namenode.rpc-address",
+                    ((String) hdfsSite.get("dfs.namenode.rpc-address")).replace("0.0.0.0", namenodeList.get(0)));
+            hdfsSite.put(
+                    "dfs.datanode.https.address",
+                    ((String) hdfsSite.get("dfs.datanode.https.address")).replace("0.0.0.0", namenodeList.get(0)));
+            hdfsSite.put(
+                    "dfs.namenode.https-address",
+                    ((String) hdfsSite.get("dfs.namenode.https-address")).replace("0.0.0.0", namenodeList.get(0)));
         }
 
         dfsDataDir = (String) hdfsSite.get("dfs.datanode.data.dir");