Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-16221. RBF: Add usage of refreshCallQueue for Router (#3421)

This commit is contained in:
Symious 2021-09-12 19:52:47 +08:00 committed by GitHub
parent 4d18a2eb99
commit 7f6553af75
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/tools/federation/RouterAdmin.java
View File

@ -135,7 +135,7 @@ private String getUsage(String cmd) {
"-setStorageTypeQuota", "-clrQuota", "-clrStorageTypeQuota",
"-safemode", "-nameservice", "-getDisabledNameservices",
"-refresh", "-refreshRouterArgs",
"-refreshSuperUserGroupsConfiguration"};
"-refreshSuperUserGroupsConfiguration", "-refreshCallQueue"};
StringBuilder usage = new StringBuilder();
usage.append("Usage: hdfs dfsrouteradmin :\n");
for (int i = 0; i < commands.length; i++) {
@ -185,6 +185,8 @@ private String getUsage(String cmd) {
return "\t[-refreshRouterArgs <host:ipc_port> <key> [arg1..argn]]";
} else if (cmd.equals("-refreshSuperUserGroupsConfiguration")) {
return "\t[-refreshSuperUserGroupsConfiguration]";
} else if (cmd.equals("-refreshCallQueue")) {
return "\t[-refreshCallQueue]";
}
return getUsage(null);
}
@ -222,6 +224,10 @@ private void validateMax(String[] arg) {
if (arg.length > 1) {
throw new IllegalArgumentException("No arguments allowed");
}
} else if (arg[0].equals("-refreshCallQueue")) {
if (arg.length > 1) {
throw new IllegalArgumentException("No arguments allowed");
}
}
}

10
hadoop-hdfs-project/hadoop-hdfs-rbf/src/test/java/org/apache/hadoop/hdfs/server/federation/router/TestRouterAdminCLI.java
View File

@ -1744,9 +1744,19 @@ public void testErrorFaultTolerant() throws Exception {
public void testRefreshCallQueue() throws Exception {
System.setOut(new PrintStream(out));
System.setErr(new PrintStream(err));
String[] argv = new String[]{"-refreshCallQueue"};
assertEquals(0, ToolRunner.run(admin, argv));
assertTrue(out.toString().contains("Refresh call queue successfully"));
argv = new String[]{};
assertEquals(-1, ToolRunner.run(admin, argv));
assertTrue(out.toString().contains("-refreshCallQueue"));
argv = new String[]{"-refreshCallQueue", "redundant"};
assertEquals(-1, ToolRunner.run(admin, argv));
assertTrue(err.toString().contains("No arguments allowed"));
}
private void addMountTable(String src, String nsId, String dst)

2
hadoop-hdfs-project/hadoop-hdfs/src/site/markdown/HDFSCommands.md
View File

@ -458,6 +458,7 @@ Usage:
[-refresh]
[-refreshRouterArgs <host:ipc_port> <key> [arg1..argn]]
[-refreshSuperUserGroupsConfiguration]
[-refreshCallQueue]
| COMMAND\_OPTION | Description |
|:---- |:---- |
@ -476,6 +477,7 @@ Usage:
| `-refresh` | Update mount table cache of the connected router. |
| `refreshRouterArgs` \<host:ipc\_port\> \<key\> [arg1..argn] | To trigger a runtime-refresh of the resource specified by \<key\> on \<host:ipc\_port\>. For example, to enable white list checking, we just need to send a refresh command other than restart the router server. |
| `-refreshSuperUserGroupsConfiguration` | Refresh superuser proxy groups mappings on Router. |
| `-refreshCallQueue` | Reload the call queue from config for Router. |
The commands for managing Router-based federation. See [Mount table management](../hadoop-hdfs-rbf/HDFSRouterFederation.html#Mount_table_management) for more info.