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

HDFS-6714. TestBlocksScheduledCounter#testBlocksScheduledCounter should shutdown cluster (vinayakumarb)

This commit is contained in:
Vinayakumar B 2014-09-05 10:25:09 +05:30
parent 6104520369
commit 772d1fb01e
2 changed files with 18 additions and 3 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

@ -697,6 +697,9 @@ Release 2.6.0 - UNRELEASED
HDFS-6905. fs-encryption merge triggered release audit failures. (clamb via tucu) HDFS-6905. fs-encryption merge triggered release audit failures. (clamb via tucu)
HDFS-6714. TestBlocksScheduledCounter#testBlocksScheduledCounter should
shutdown cluster (vinayakumarb)
Release 2.5.1 - UNRELEASED Release 2.5.1 - UNRELEASED
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

18
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestBlocksScheduledCounter.java
View File

@ -27,6 +27,7 @@
import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor; import org.apache.hadoop.hdfs.server.blockmanagement.DatanodeDescriptor;
import org.apache.hadoop.hdfs.server.blockmanagement.DatanodeManager; import org.apache.hadoop.hdfs.server.blockmanagement.DatanodeManager;
import org.junit.After;
import org.junit.Test; import org.junit.Test;
/** /**
@ -35,14 +36,25 @@
* scheduled to a datanode. * scheduled to a datanode.
*/ */
public class TestBlocksScheduledCounter { public class TestBlocksScheduledCounter {
MiniDFSCluster cluster = null;
FileSystem fs = null;
@After
public void tearDown() throws IOException {
if (fs != null) {
fs.close();
}
if(cluster!=null){
cluster.shutdown();
}
}
@Test @Test
public void testBlocksScheduledCounter() throws IOException { public void testBlocksScheduledCounter() throws IOException {
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration()) cluster = new MiniDFSCluster.Builder(new HdfsConfiguration()).build();
.build();
cluster.waitActive(); cluster.waitActive();
FileSystem fs = cluster.getFileSystem(); fs = cluster.getFileSystem();
//open a file an write a few bytes: //open a file an write a few bytes:
FSDataOutputStream out = fs.create(new Path("/testBlockScheduledCounter")); FSDataOutputStream out = fs.create(new Path("/testBlockScheduledCounter"));