Skip to content

Commit da709ae

Browse files
committed
fix failed unit test.
1 parent 3f5e749 commit da709ae

File tree

3 files changed

+8
-7
lines changed

3 files changed

+8
-7
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -26,18 +26,18 @@ public class DFSRouterFaultInjector {
2626
@VisibleForTesting
2727
private static DFSRouterFaultInjector instance =
2828
new DFSRouterFaultInjector();
29-
29+
3030
@VisibleForTesting
3131
public static DFSRouterFaultInjector get() {
3232
return instance;
3333
}
3434

3535
public static void set(DFSRouterFaultInjector injector) {
3636
instance = injector;
37-
}
38-
37+
}
38+
3939
@VisibleForTesting
4040
public boolean shouldSkipShutdownAsyncExecutors() {
41-
return false;
41+
return true;
4242
}
4343
}

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -510,6 +510,7 @@ private void shutdownAsyncRouterRpcExecutors() {
510510

511511
/**
512512
* Init router async handlers and router async responders.
513+
* @param configuration the configuration.
513514
*/
514515
public void initAsyncThreadPools(Configuration configuration) {
515516
LOG.info("Begin initialize asynchronous handler and responder thread pool.");

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/resources/hdfs-rbf-default.xml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -136,15 +136,15 @@
136136
</property>
137137

138138
<property>
139-
<name>dfs.federation.router.rpc.async.handler.count</name>
140-
<value>2</value>
139+
<name>dfs.federation.router.async.rpc.handler.count</name>
140+
<value>10</value>
141141
<description>
142142
The number of async handler for the router to handle RPC client requests.
143143
</description>
144144
</property>
145145

146146
<property>
147-
<name>dfs.federation.router.rpc.async.responder.count</name>
147+
<name>dfs.federation.router.async.rpc.responder.count</name>
148148
<value>10</value>
149149
<description>
150150
The number of async responder for the router to handle responses.

0 commit comments

Comments
 (0)