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

HDFS-13336. Test cases of TestWriteToReplica failed in windows. Contributed by Xiao Liang. 

(cherry picked from commit df92a17e02)
This commit is contained in:
Inigo Goiri 2018-04-23 19:12:16 -07:00
parent 99e82e2c2c
commit db9da432b9
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
View File

@ -20,6 +20,7 @@ package org.apache.hadoop.hdfs.server.datanode.fsdataset.impl;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.ArrayList;
@ -63,7 +64,8 @@ public class TestWriteToReplica {
// test close
@Test
public void testClose() throws Exception {
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration()).build();
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration(),
new File(GenericTestUtils.getRandomizedTempPath())).build();
try {
cluster.waitActive();
@ -85,7 +87,8 @@ public class TestWriteToReplica {
// test append
@Test
public void testAppend() throws Exception {
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration()).build();
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration(),
new File(GenericTestUtils.getRandomizedTempPath())).build();
try {
cluster.waitActive();
DataNode dn = cluster.getDataNodes().get(0);
@ -105,7 +108,8 @@ public class TestWriteToReplica {
// test writeToRbw
@Test
public void testWriteToRbw() throws Exception {
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration()).build();
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration(),
new File(GenericTestUtils.getRandomizedTempPath())).build();
try {
cluster.waitActive();
DataNode dn = cluster.getDataNodes().get(0);
@ -125,7 +129,8 @@ public class TestWriteToReplica {
// test writeToTemporary
@Test
public void testWriteToTemporary() throws Exception {
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration()).build();
MiniDFSCluster cluster = new MiniDFSCluster.Builder(new HdfsConfiguration(),
new File(GenericTestUtils.getRandomizedTempPath())).build();
try {
cluster.waitActive();
DataNode dn = cluster.getDataNodes().get(0);
@ -507,7 +512,8 @@ public class TestWriteToReplica {
@Test
public void testReplicaMapAfterDatanodeRestart() throws Exception {
Configuration conf = new HdfsConfiguration();
MiniDFSCluster cluster = new MiniDFSCluster.Builder(conf)
MiniDFSCluster cluster = new MiniDFSCluster.Builder(conf,
new File(GenericTestUtils.getRandomizedTempPath()))
.nnTopology(MiniDFSNNTopology.simpleFederatedTopology(2))
.build();
try {
@ -561,7 +567,8 @@ public class TestWriteToReplica {
@Test
public void testRecoverInconsistentRbw() throws IOException {
Configuration conf = new HdfsConfiguration();
MiniDFSCluster cluster = new MiniDFSCluster.Builder(conf).build();
MiniDFSCluster cluster = new MiniDFSCluster.Builder(conf,
new File(GenericTestUtils.getRandomizedTempPath())).build();
cluster.waitActive();
DataNode dn = cluster.getDataNodes().get(0);
FsDatasetImpl fsDataset = (FsDatasetImpl)DataNodeTestUtils.getFSDataset(dn);