From 3729c086326e46337adb62a62b6d8197cbb700d8 Mon Sep 17 00:00:00 2001 From: timyuer <524860213@qq.com> Date: Wed, 11 Sep 2024 12:59:45 +0800 Subject: [PATCH] fix hadoop --- .../server/service/impl/JobServiceImpl.java | 3 ++- .../stack/bigtop/v3_3_0/hdfs/HdfsParams.java | 15 +++++++++++---- 2 files changed, 13 insertions(+), 5 deletions(-) diff --git a/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/service/impl/JobServiceImpl.java b/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/service/impl/JobServiceImpl.java index 77b4c2dc..b6a30a3c 100644 --- a/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/service/impl/JobServiceImpl.java +++ b/bigtop-manager-server/src/main/java/org/apache/bigtop/manager/server/service/impl/JobServiceImpl.java @@ -79,7 +79,8 @@ public PageVO list(Long clusterId) { jobPOList = jobDao.findAllByClusterId(clusterId); } PageInfo pageInfo = new PageInfo<>(jobPOList); - List allByIdsJoin = jobDao.findAllByIdsJoin(jobPOList.stream().map(JobPO::getId).toList()); + List allByIdsJoin = + jobDao.findAllByIdsJoin(jobPOList.stream().map(JobPO::getId).toList()); pageInfo.setList(allByIdsJoin); return PageVO.of(pageInfo); diff --git a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hdfs/HdfsParams.java b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hdfs/HdfsParams.java index 10031044..b8fb1217 100644 --- a/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hdfs/HdfsParams.java +++ b/bigtop-manager-stack/bigtop-manager-stack-bigtop/src/main/java/org/apache/bigtop/manager/stack/bigtop/v3_3_0/hdfs/HdfsParams.java @@ -85,7 +85,8 @@ public Map coreSite() { Map coreSite = LocalSettings.configurations(serviceName(), "core-site"); List 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 hdfsSite() { Map hdfsSite = LocalSettings.configurations(serviceName(), "hdfs-site"); List 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");