Skip to content

Commit 85599bd

Browse files
committed
fix checkstyle
1 parent 573263a commit 85599bd

File tree

2 files changed

+33
-46
lines changed

2 files changed

+33
-46
lines changed

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterNetworkTopologyServlet.java

Lines changed: 4 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -19,19 +19,10 @@
1919

2020
import com.fasterxml.jackson.core.JsonFactory;
2121
import com.fasterxml.jackson.core.JsonGenerator;
22-
import org.apache.hadoop.conf.Configuration;
2322
import org.apache.hadoop.hdfs.protocol.DatanodeInfo;
2423
import org.apache.hadoop.hdfs.protocol.HdfsConstants;
25-
import org.apache.hadoop.hdfs.server.blockmanagement.BlockManager;
26-
import org.apache.hadoop.hdfs.server.common.JspHelper;
27-
import org.apache.hadoop.hdfs.server.namenode.NameNode;
28-
import org.apache.hadoop.hdfs.server.namenode.NameNodeHttpServer;
29-
import org.apache.hadoop.hdfs.server.namenode.NetworkTopologyServlet;
30-
import org.apache.hadoop.http.IsActiveServlet;
3124
import org.apache.hadoop.net.NetUtils;
3225
import org.apache.hadoop.net.Node;
33-
import org.apache.hadoop.net.NodeBase;
34-
import org.apache.hadoop.security.UserGroupInformation;
3526
import org.apache.hadoop.thirdparty.com.google.common.annotations.VisibleForTesting;
3627
import org.apache.hadoop.util.StringUtils;
3728

@@ -42,14 +33,9 @@
4233
import javax.ws.rs.core.HttpHeaders;
4334
import java.io.IOException;
4435
import java.io.PrintStream;
45-
import java.io.PrintWriter;
46-
import java.net.HttpURLConnection;
47-
import java.net.InetAddress;
48-
import java.security.PrivilegedExceptionAction;
4936
import java.util.ArrayList;
5037
import java.util.Collections;
5138
import java.util.HashMap;
52-
import java.util.List;
5339
import java.util.Map;
5440
import java.util.TreeSet;
5541

@@ -78,7 +64,8 @@ public void doGet(HttpServletRequest request, HttpServletResponse response)
7864

7965
Router router = RouterHttpServer.getRouterFromContext(context);
8066
DatanodeInfo[] datanodeReport =
81-
router.getRpcServer().getDatanodeReport(HdfsConstants.DatanodeReportType.ALL);
67+
router.getRpcServer().getDatanodeReport(
68+
HdfsConstants.DatanodeReportType.ALL);
8269

8370
try (PrintStream out = new PrintStream(
8471
response.getOutputStream(), false, "UTF-8")) {
@@ -103,7 +90,7 @@ public void doGet(HttpServletRequest request, HttpServletResponse response)
10390
* @param format the response format
10491
*/
10592
public void printTopology(PrintStream stream, DatanodeInfo[] datanodeInfos,
106-
String format) throws NetworkTopologyServlet.BadFormatException, IOException {
93+
String format) throws IOException, BadFormatException {
10794
if (datanodeInfos.length == 0) {
10895
stream.print("No DataNodes");
10996
return;
@@ -128,7 +115,7 @@ public void printTopology(PrintStream stream, DatanodeInfo[] datanodeInfos,
128115
} else if (FORMAT_TEXT.equals(format)) {
129116
printTextFormat(stream, tree, racks);
130117
} else {
131-
throw new NetworkTopologyServlet.BadFormatException("Bad format: " + format);
118+
throw new BadFormatException("Bad format: " + format);
132119
}
133120
}
134121

hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterNetworkTopologyServlet.java

Lines changed: 29 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -151,11 +151,11 @@ public void testPrintTopologyJsonFormat() throws Exception {
151151
Iterator<JsonNode> elements = racks.elements();
152152
int dataNodesCount = 0;
153153
while(elements.hasNext()){
154-
JsonNode rack = elements.next();
155-
Iterator<Map.Entry<String, JsonNode>> fields = rack.fields();
156-
while (fields.hasNext()) {
157-
dataNodesCount += fields.next().getValue().size();
158-
}
154+
JsonNode rack = elements.next();
155+
Iterator<Map.Entry<String, JsonNode>> fields = rack.fields();
156+
while (fields.hasNext()) {
157+
dataNodesCount += fields.next().getValue().size();
158+
}
159159
}
160160
assertEquals(dataNodesCount, 18);
161161
}
@@ -184,28 +184,28 @@ public void testPrintTopologyNoDatanodesTextFormat() throws Exception {
184184
assertTrue(topology.contains("No DataNodes"));
185185
}
186186

187-
@Test
188-
public void testPrintTopologyNoDatanodesJsonFormat() throws Exception {
189-
// get http Address
190-
String httpAddress = clusterNoDatanodes.getRandomRouter().getRouter()
191-
.getHttpServerAddress().toString();
192-
193-
// send http request
194-
URL url = new URL("http:/" + httpAddress + "/topology");
195-
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
196-
conn.setReadTimeout(20000);
197-
conn.setConnectTimeout(20000);
198-
conn.setRequestProperty("Accept", "application/json");
199-
conn.connect();
200-
ByteArrayOutputStream out = new ByteArrayOutputStream();
201-
IOUtils.copyBytes(conn.getInputStream(), out, 4096, true);
202-
StringBuilder sb =
203-
new StringBuilder("-- Network Topology -- \n");
204-
sb.append(out);
205-
sb.append("\n-- Network Topology -- ");
206-
String topology = sb.toString();
207-
208-
// assert node number
209-
assertTrue(topology.contains("No DataNodes"));
210-
}
187+
@Test
188+
public void testPrintTopologyNoDatanodesJsonFormat() throws Exception {
189+
// get http Address
190+
String httpAddress = clusterNoDatanodes.getRandomRouter().getRouter()
191+
.getHttpServerAddress().toString();
192+
193+
// send http request
194+
URL url = new URL("http:/" + httpAddress + "/topology");
195+
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
196+
conn.setReadTimeout(20000);
197+
conn.setConnectTimeout(20000);
198+
conn.setRequestProperty("Accept", "application/json");
199+
conn.connect();
200+
ByteArrayOutputStream out = new ByteArrayOutputStream();
201+
IOUtils.copyBytes(conn.getInputStream(), out, 4096, true);
202+
StringBuilder sb =
203+
new StringBuilder("-- Network Topology -- \n");
204+
sb.append(out);
205+
sb.append("\n-- Network Topology -- ");
206+
String topology = sb.toString();
207+
208+
// assert node number
209+
assertTrue(topology.contains("No DataNodes"));
210+
}
211211
}

0 commit comments

Comments
 (0)