diff --git a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestOzoneManagerRestInterface.java b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestOzoneManagerRestInterface.java index a1a7ac448a9..f3a92c014e5 100644 --- a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestOzoneManagerRestInterface.java +++ b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/om/TestOzoneManagerRestInterface.java @@ -21,7 +21,6 @@ import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.core.type.TypeReference; import org.apache.hadoop.hdds.conf.OzoneConfiguration; -import org.apache.hadoop.hdds.protocol.DatanodeDetails; import org.apache.hadoop.net.NetUtils; import org.apache.hadoop.ozone.MiniOzoneCluster; import org.apache.hadoop.ozone.om.helpers.ServiceInfo; @@ -114,30 +113,6 @@ public void testGetServiceList() throws Exception { Assert.assertEquals(scmAddress.getHostName(), scmInfo.getHostname()); Assert.assertEquals(scmAddress.getPort(), scmInfo.getPort(ServicePort.Type.RPC)); - - ServiceInfo datanodeInfo = serviceMap.get(HddsProtos.NodeType.DATANODE); - DatanodeDetails datanodeDetails = cluster.getHddsDatanodes().get(0) - .getDatanodeDetails(); - Assert.assertEquals(datanodeDetails.getHostName(), - datanodeInfo.getHostname()); - - Map ports = datanodeInfo.getPorts(); - for(ServicePort.Type type : ports.keySet()) { - switch (type) { - case HTTP: - case HTTPS: - Assert.assertEquals( - datanodeDetails.getPort(DatanodeDetails.Port.Name.REST).getValue(), - ports.get(type)); - break; - default: - // OM only sends Datanode's info port details - // i.e. HTTP or HTTPS - // Other ports are not expected as of now. - Assert.fail(); - break; - } - } } } diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java index 2fde315db8d..893934c41cc 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/OzoneManager.java @@ -54,7 +54,6 @@ import org.apache.hadoop.hdds.HddsUtils; import org.apache.hadoop.hdds.annotation.InterfaceAudience; import org.apache.hadoop.hdds.conf.OzoneConfiguration; -import org.apache.hadoop.hdds.protocol.DatanodeDetails; import org.apache.hadoop.hdds.protocol.proto.HddsProtos; import org.apache.hadoop.hdds.protocol.proto.SCMSecurityProtocolProtos.SCMGetCertResponseProto; import org.apache.hadoop.hdds.protocolPB.SCMSecurityProtocolClientSideTranslatorPB; @@ -175,7 +174,6 @@ import static org.apache.hadoop.hdds.HddsConfigKeys.HDDS_BLOCK_TOKEN_ENABLED_DEFAULT; import static org.apache.hadoop.hdds.HddsUtils.getScmAddressForBlockClients; import static org.apache.hadoop.hdds.HddsUtils.getScmAddressForClients; -import static org.apache.hadoop.hdds.protocol.proto.HddsProtos.NodeState.HEALTHY; import static org.apache.hadoop.hdds.security.x509.certificates.utils.CertificateSignRequest.getEncodedString; import static org.apache.hadoop.hdds.server.ServerUtils.getRemoteUserName; import static org.apache.hadoop.hdds.server.ServerUtils.updateRPCListenAddress; @@ -2481,28 +2479,6 @@ public List getServiceList() throws IOException { .setValue(scmAddr.getPort()).build()); services.add(scmServiceInfoBuilder.build()); - List nodes = scmContainerClient.queryNode(HEALTHY, - HddsProtos.QueryScope.CLUSTER, ""); - - for (HddsProtos.Node node : nodes) { - HddsProtos.DatanodeDetailsProto datanode = node.getNodeID(); - - ServiceInfo.Builder dnServiceInfoBuilder = ServiceInfo.newBuilder() - .setNodeType(HddsProtos.NodeType.DATANODE) - .setHostname(datanode.getHostName()); - - if (DatanodeDetails.getFromProtoBuf(datanode) - .getPort(DatanodeDetails.Port.Name.REST) != null) { - dnServiceInfoBuilder.addServicePort(ServicePort.newBuilder() - .setType(ServicePort.Type.HTTP) - .setValue(DatanodeDetails.getFromProtoBuf(datanode) - .getPort(DatanodeDetails.Port.Name.REST).getValue()) - .build()); - } - - services.add(dnServiceInfoBuilder.build()); - } - metrics.incNumGetServiceLists(); // For now there is no exception that can can happen in this call, // so failure metrics is not handled. In future if there is any need to