Skip to content

Commit 06c83a4

Browse files
author
zengqiang.xu
committed
HDFS-16728. modify patch based on comments
1 parent ee94b04 commit 06c83a4

File tree

2 files changed

+3
-3
lines changed
  • hadoop-hdfs-project/hadoop-hdfs-rbf/src

2 files changed

+3
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1765,7 +1765,7 @@ protected List<RemoteLocation> getLocationsForPath(String path,
17651765
}
17661766
}
17671767
if (locs.isEmpty()) {
1768-
throw new NoLocationException(path, this.subclusterResolver.getClass().getSimpleName());
1768+
throw new NoLocationException(path, this.subclusterResolver.getClass());
17691769
}
17701770
return locs;
17711771
} catch (IOException ioe) {

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1558,9 +1558,9 @@ public void testMkdirWithDisableNameService() throws Exception {
15581558

15591559
try {
15601560
FsPermission permission = new FsPermission("777");
1561+
RouterRpcServer rpcServer = router.getRouter().getRpcServer();
15611562
LambdaTestUtils.intercept(NoLocationException.class,
1562-
() -> router.getRouter().getRpcServer()
1563-
.mkdirs("/mnt/folder0/folder1", permission, true));
1563+
() -> rpcServer.mkdirs("/mnt/folder0/folder1", permission, true));
15641564
} finally {
15651565
activeNamenodeResolver.clearDisableNamespaces();
15661566
}

0 commit comments

Comments
 (0)