diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java index a37e7436c8703..9861b9799320f 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/RouterRpcServer.java @@ -40,7 +40,6 @@ import static org.apache.hadoop.hdfs.server.federation.router.RouterRpcClient.isExpectedClass; import static org.apache.hadoop.hdfs.server.federation.router.async.AsyncUtil.asyncApply; import static org.apache.hadoop.hdfs.server.federation.router.async.AsyncUtil.asyncCatch; -import static org.apache.hadoop.hdfs.server.federation.router.async.AsyncUtil.asyncComplete; import static org.apache.hadoop.hdfs.server.federation.router.async.AsyncUtil.asyncForEach; import static org.apache.hadoop.hdfs.server.federation.router.async.AsyncUtil.asyncReturn; import static org.apache.hadoop.hdfs.server.federation.router.async.AsyncUtil.asyncTry; diff --git a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterAsyncStoragePolicy.java b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterAsyncStoragePolicy.java index a1bc639617eac..9de314a0777cc 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterAsyncStoragePolicy.java +++ b/hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterAsyncStoragePolicy.java @@ -144,7 +144,8 @@ public void tearDown() throws IOException { @Test public void testRouterAsyncStoragePolicy() throws Exception { - BlockStoragePolicy[] storagePolicies = cluster.getNamenodes().get(0).getClient().getStoragePolicies(); + BlockStoragePolicy[] storagePolicies = cluster.getNamenodes().get(0) + .getClient().getStoragePolicies(); asyncStoragePolicy.getStoragePolicies(); BlockStoragePolicy[] storagePoliciesAsync = syncReturn(BlockStoragePolicy[].class); assertArrayEquals(storagePolicies, storagePoliciesAsync);