|
@@ -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);
|