Skip to content

Commit 0cdc544

Browse files
committed
optimize javadoc
1 parent 487f947 commit 0cdc544

File tree

2 files changed

+8
-4
lines changed

2 files changed

+8
-4
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,9 @@
3030
import static org.apache.hadoop.hdfs.server.federation.router.RBFConfigKeys.
3131
DFS_ROUTER_ASYNC_RPC_MAX_ASYNC_CALL_PERMIT_DEFAULT;
3232

33+
/**
34+
* When router async rpc enabled, it is recommended to use this fairness controller.
35+
*/
3336
public class RouterAsyncRpcFairnessPolicyController extends
3437
AbstractRouterRpcFairnessPolicyController {
3538

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

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -45,16 +45,17 @@ public class TestRouterAsyncRpc extends TestRouterRpc {
4545

4646
@BeforeClass
4747
public static void globalSetUp() throws Exception {
48-
// Start routers with only an RPC service
48+
// Start routers with only an RPC service.
4949
Configuration routerConf = new RouterConfigBuilder()
5050
.metrics()
5151
.rpc()
5252
.build();
53-
// We decrease the DN cache times to make the test faster
53+
// We decrease the DN cache times to make the test faster.
5454
routerConf.setTimeDuration(
5555
RBFConfigKeys.DN_REPORT_CACHE_EXPIRE, 1, TimeUnit.SECONDS);
56-
// use async router.
56+
// Use async router.
5757
routerConf.setBoolean(DFS_ROUTER_ASYNC_RPC_ENABLE_KEY, true);
58+
// Use RouterAsyncRpcFairnessPolicyController as the fairness controller.
5859
routerConf.setClass(DFS_ROUTER_FAIRNESS_POLICY_CONTROLLER_CLASS,
5960
RouterAsyncRpcFairnessPolicyController.class,
6061
RouterRpcFairnessPolicyController.class);
@@ -65,7 +66,7 @@ public static void globalSetUp() throws Exception {
6566
public void testSetup() throws Exception {
6667
super.testSetup();
6768
cluster = super.getCluster();
68-
// Random router for this test
69+
// Random router for this test.
6970
rndRouter = cluster.getRandomRouter();
7071
}
7172

0 commit comments

Comments
 (0)