big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HDFS-16271. RBF: NullPointerException when setQuota through routers with quota disabled. Contributed by Chengwei Wang.

Browse Source
This commit is contained in:
Ayush Saxena 2021-10-16 14:25:00 +05:30
parent af920f138b
commit 5b1cf17f88
No known key found for this signature in database
GPG Key ID: D09AE71061AB564D
2 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/Quota.java
View File

@ -80,6 +80,9 @@ public Quota(Router router, RouterRpcServer server) {
*/ */
public void setQuota(String path, long namespaceQuota, long storagespaceQuota, public void setQuota(String path, long namespaceQuota, long storagespaceQuota,
StorageType type, boolean checkMountEntry) throws IOException { StorageType type, boolean checkMountEntry) throws IOException {
if (!router.isQuotaEnabled()) {
throw new IOException("The quota system is disabled in Router.");
}
if (checkMountEntry && isMountEntry(path)) { if (checkMountEntry && isMountEntry(path)) {
throw new AccessControlException( throw new AccessControlException(
"Permission denied: " + RouterRpcServer.getRemoteUser() "Permission denied: " + RouterRpcServer.getRemoteUser()
@ -101,9 +104,6 @@ void setQuotaInternal(String path, List<RemoteLocation> locations,
long namespaceQuota, long storagespaceQuota, StorageType type) long namespaceQuota, long storagespaceQuota, StorageType type)
throws IOException { throws IOException {
rpcServer.checkOperation(OperationCategory.WRITE); rpcServer.checkOperation(OperationCategory.WRITE);
if (!router.isQuotaEnabled()) {
throw new IOException("The quota system is disabled in Router.");
}
// Set quota for current path and its children mount table path. // Set quota for current path and its children mount table path.
if (locations == null) { if (locations == null) {

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

@ -70,15 +70,21 @@ public void checkDisableQuota() {
public void testSetQuota() throws Exception { public void testSetQuota() throws Exception {
long nsQuota = 1024; long nsQuota = 1024;
long ssQuota = 1024; long ssQuota = 1024;
Quota quotaModule = router.getRpcServer().getQuotaModule();
try { // don't checkMountEntry called by RouterAdminServer#synchronizeQuota
Quota quotaModule = router.getRpcServer().getQuotaModule(); LambdaTestUtils.intercept(
quotaModule.setQuota("/test", nsQuota, ssQuota, null, false); IOException.class,
fail("The setQuota call should fail."); "The quota system is disabled in Router.",
} catch (IOException ioe) { "The setQuota call should fail.",
GenericTestUtils.assertExceptionContains( () -> quotaModule.setQuota("/test", nsQuota, ssQuota, null, false));
"The quota system is disabled in Router.", ioe);
} // do checkMountEntry called by RouterClientProtocol#setQuota
LambdaTestUtils.intercept(
IOException.class,
"The quota system is disabled in Router.",
"The setQuota call should fail.",
() -> quotaModule.setQuota("/test", nsQuota, ssQuota, null, true));
} }
@Test @Test