You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by in...@apache.org on 2018/04/24 02:14:57 UTC
[1/5] hadoop git commit: HDFS-13336. Test cases of TestWriteToReplica
failed in windows. Contributed by Xiao Liang.
Repository: hadoop
Updated Branches:
refs/heads/branch-2 99e82e2c2 -> db9da432b
refs/heads/branch-2.9 74e5b4b43 -> f16472476
refs/heads/branch-3.0 101d9005d -> 7bb2709c4
refs/heads/branch-3.1 ea7ad5049 -> 5b2427cd7
refs/heads/trunk 9b5375e0c -> df92a17e0
HDFS-13336. Test cases of TestWriteToReplica failed in windows. Contributed by Xiao Liang.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/df92a17e
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/df92a17e
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/df92a17e
Branch: refs/heads/trunk
Commit: df92a17e02fe86279a6f4e413719d0a465b50837
Parents: 9b5375e
Author: Inigo Goiri <in...@apache.org>
Authored: Mon Apr 23 19:12:16 2018 -0700
Committer: Inigo Goiri <in...@apache.org>
Committed: Mon Apr 23 19:12:16 2018 -0700
----------------------------------------------------------------------
.../fsdataset/impl/TestWriteToReplica.java | 19 +++++++++++++------
1 file changed, 13 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/df92a17e/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
index 14ac95f..2c5df28 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
@@ -21,6 +21,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
+import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.ArrayList;
@@ -64,7 +65,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();
@@ -86,7 +88,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);
@@ -106,7 +109,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);
@@ -126,7 +130,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);
@@ -512,7 +517,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 {
@@ -566,7 +572,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);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org
[3/5] hadoop git commit: HDFS-13336. Test cases of TestWriteToReplica
failed in windows. Contributed by Xiao Liang.
Posted by in...@apache.org.
HDFS-13336. Test cases of TestWriteToReplica failed in windows. Contributed by Xiao Liang.
(cherry picked from commit df92a17e02fe86279a6f4e413719d0a465b50837)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/7bb2709c
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/7bb2709c
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/7bb2709c
Branch: refs/heads/branch-3.0
Commit: 7bb2709c4aea8975dfec34db86ccb9d9e60fdbba
Parents: 101d900
Author: Inigo Goiri <in...@apache.org>
Authored: Mon Apr 23 19:12:16 2018 -0700
Committer: Inigo Goiri <in...@apache.org>
Committed: Mon Apr 23 19:13:25 2018 -0700
----------------------------------------------------------------------
.../fsdataset/impl/TestWriteToReplica.java | 19 +++++++++++++------
1 file changed, 13 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/7bb2709c/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
index 14ac95f..2c5df28 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
@@ -21,6 +21,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
+import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.ArrayList;
@@ -64,7 +65,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();
@@ -86,7 +88,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);
@@ -106,7 +109,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);
@@ -126,7 +130,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);
@@ -512,7 +517,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 {
@@ -566,7 +572,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);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org
[2/5] hadoop git commit: HDFS-13336. Test cases of TestWriteToReplica
failed in windows. Contributed by Xiao Liang.
Posted by in...@apache.org.
HDFS-13336. Test cases of TestWriteToReplica failed in windows. Contributed by Xiao Liang.
(cherry picked from commit df92a17e02fe86279a6f4e413719d0a465b50837)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/5b2427cd
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/5b2427cd
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/5b2427cd
Branch: refs/heads/branch-3.1
Commit: 5b2427cd732e84eac23f5dff8ca39313396cab2e
Parents: ea7ad50
Author: Inigo Goiri <in...@apache.org>
Authored: Mon Apr 23 19:12:16 2018 -0700
Committer: Inigo Goiri <in...@apache.org>
Committed: Mon Apr 23 19:12:53 2018 -0700
----------------------------------------------------------------------
.../fsdataset/impl/TestWriteToReplica.java | 19 +++++++++++++------
1 file changed, 13 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/5b2427cd/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
index 14ac95f..2c5df28 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
@@ -21,6 +21,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.fail;
+import java.io.File;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.util.ArrayList;
@@ -64,7 +65,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();
@@ -86,7 +88,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);
@@ -106,7 +109,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);
@@ -126,7 +130,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);
@@ -512,7 +517,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 {
@@ -566,7 +572,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);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org
[4/5] hadoop git commit: HDFS-13336. Test cases of TestWriteToReplica
failed in windows. Contributed by Xiao Liang.
Posted by in...@apache.org.
HDFS-13336. Test cases of TestWriteToReplica failed in windows. Contributed by Xiao Liang.
(cherry picked from commit df92a17e02fe86279a6f4e413719d0a465b50837)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/db9da432
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/db9da432
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/db9da432
Branch: refs/heads/branch-2
Commit: db9da432b9ae343bf13c4f3ed45e4c8b8c20a84f
Parents: 99e82e2
Author: Inigo Goiri <in...@apache.org>
Authored: Mon Apr 23 19:12:16 2018 -0700
Committer: Inigo Goiri <in...@apache.org>
Committed: Mon Apr 23 19:14:03 2018 -0700
----------------------------------------------------------------------
.../fsdataset/impl/TestWriteToReplica.java | 19 +++++++++++++------
1 file changed, 13 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/db9da432/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
index e7c680c..f6b1688 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
@@ -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);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org
[5/5] hadoop git commit: HDFS-13336. Test cases of TestWriteToReplica
failed in windows. Contributed by Xiao Liang.
Posted by in...@apache.org.
HDFS-13336. Test cases of TestWriteToReplica failed in windows. Contributed by Xiao Liang.
(cherry picked from commit df92a17e02fe86279a6f4e413719d0a465b50837)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/f1647247
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f1647247
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f1647247
Branch: refs/heads/branch-2.9
Commit: f16472476177c7afd1c2e2c1804e1ca0b9ab309c
Parents: 74e5b4b
Author: Inigo Goiri <in...@apache.org>
Authored: Mon Apr 23 19:12:16 2018 -0700
Committer: Inigo Goiri <in...@apache.org>
Committed: Mon Apr 23 19:14:35 2018 -0700
----------------------------------------------------------------------
.../fsdataset/impl/TestWriteToReplica.java | 19 +++++++++++++------
1 file changed, 13 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/f1647247/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
index e7c680c..f6b1688 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/fsdataset/impl/TestWriteToReplica.java
@@ -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);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org