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

HDFS-9413. getContentSummary() on standby should throw StandbyException. (Brahma Reddy Battula via mingma)

Browse Source
This commit is contained in:
Ming Ma 2015-11-16 09:32:40 -08:00
parent 855d52927b
commit 02653add98
3 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt
View File

@ -2302,6 +2302,9 @@ Release 2.8.0 - UNRELEASED
HDFS-9410. Some tests should always reset sysout and syserr. HDFS-9410. Some tests should always reset sysout and syserr.
(Xiao Chen via waltersu4549) (Xiao Chen via waltersu4549)
HDFS-9413. getContentSummary() on standby should throw StandbyException.
(Brahma Reddy Battula via mingma)
Release 2.7.3 - UNRELEASED Release 2.7.3 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

2
hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java
View File

@ -2948,9 +2948,11 @@ boolean mkdirs(String src, PermissionStatus permissions,
* or null if file not found * or null if file not found
*/ */
ContentSummary getContentSummary(final String src) throws IOException { ContentSummary getContentSummary(final String src) throws IOException {
checkOperation(OperationCategory.READ);
readLock(); readLock();
boolean success = true; boolean success = true;
try { try {
checkOperation(OperationCategory.READ);
return FSDirStatAndListingOp.getContentSummary(dir, src); return FSDirStatAndListingOp.getContentSummary(dir, src);
} catch (AccessControlException ace) { } catch (AccessControlException ace) {
success = false; success = false;

15
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestQuotasWithHA.java
View File

@ -17,6 +17,7 @@
*/ */
package org.apache.hadoop.hdfs.server.namenode.ha; package org.apache.hadoop.hdfs.server.namenode.ha;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import java.io.IOException; import java.io.IOException;
@ -34,6 +35,7 @@
import org.apache.hadoop.hdfs.MiniDFSNNTopology; import org.apache.hadoop.hdfs.MiniDFSNNTopology;
import org.apache.hadoop.hdfs.server.namenode.NameNode; import org.apache.hadoop.hdfs.server.namenode.NameNode;
import org.apache.hadoop.io.IOUtils; import org.apache.hadoop.io.IOUtils;
import org.apache.hadoop.ipc.StandbyException;
import org.junit.After; import org.junit.After;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -130,4 +132,17 @@ public void testQuotasTrackedOnStandby() throws Exception {
assertEquals(1, cs.getDirectoryCount()); assertEquals(1, cs.getDirectoryCount());
assertEquals(0, cs.getFileCount()); assertEquals(0, cs.getFileCount());
} }
/**
* Test that getContentSummary on Standby should should throw standby
* exception.
*/
@Test(expected = StandbyException.class)
public void testgetContentSummaryOnStandby() throws Exception {
Configuration nn1conf =cluster.getConfiguration(1);
// just reset the standby reads to default i.e False on standby.
HAUtil.setAllowStandbyReads(nn1conf, false);
cluster.restartNameNode(1);
cluster.getNameNodeRpc(1).getContentSummary("/");
}
} }