Skip to content

Commit e33ccef

Browse files
committed
fix checkstyle and remove useless varaiable.
1 parent c5dd5cb commit e33ccef

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/fairness/RouterAsyncRpcFairnessPolicyController.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public class RouterAsyncRpcFairnessPolicyController extends
3838

3939
private static final Logger LOG =
4040
LoggerFactory.getLogger(RouterAsyncRpcFairnessPolicyController.class);
41-
41+
4242
public RouterAsyncRpcFairnessPolicyController(Configuration conf) {
4343
init(conf);
4444
}
@@ -52,7 +52,7 @@ public void init(Configuration conf) throws IllegalArgumentException {
5252
maxAsyncCallPermit = DFS_ROUTER_ASYNC_RPC_MAX_ASYNC_CALL_PERMIT_DEFAULT;
5353
}
5454
LOG.info("Max async call permits per nameservice: {}", maxAsyncCallPermit);
55-
55+
5656
// Get all name services configured
5757
Set<String> allConfiguredNS = FederationUtil.getAllConfiguredNS(conf);
5858

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

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -260,7 +260,7 @@ private void invokeMethodAsync(
260260
return handlerAllNamenodeFail(namenodes, method, ioes, params);
261261
});
262262
});
263-
263+
264264
asyncFinally(res -> {
265265
releasePermit(nsid, ugi, method, controller);
266266
return res;
@@ -576,7 +576,6 @@ public <T extends RemoteLocationContext, R> List<RemoteResult<T, R>> invokeConcu
576576
protected <T extends RemoteLocationContext, R> List<RemoteResult<T, R>> getRemoteResults(
577577
RemoteMethod method, long timeOutMs, RouterRpcFairnessPolicyController controller,
578578
List<T> orderedLocations, List<Callable<Object>> callables) throws IOException {
579-
final UserGroupInformation ugi = RouterRpcServer.getRemoteUser();
580579
final Method m = method.getMethod();
581580
final CompletableFuture<Object>[] futures =
582581
new CompletableFuture[callables.size()];
@@ -641,7 +640,7 @@ public <T extends RemoteLocationContext, R> List<RemoteResult<T, R>> invokeSingl
641640
asyncCatch((o, ioe) -> {
642641
throw processException(ioe, location);
643642
}, IOException.class);
644-
asyncFinally(o -> {
643+
asyncFinally(o -> {
645644
return o;
646645
});
647646
return asyncReturn(List.class);

0 commit comments

Comments
 (0)