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 xy...@apache.org on 2018/06/08 17:12:35 UTC
[14/50] hadoop git commit: HDFS-13650. Randomize baseDir for
MiniDFSCluster in TestDFSStripedInputStream and
TestDFSStripedInputStreamWithRandomECPolicy. Contributed by Anbang Hu.
HDFS-13650. Randomize baseDir for MiniDFSCluster in TestDFSStripedInputStream and TestDFSStripedInputStreamWithRandomECPolicy. Contributed by Anbang Hu.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/8d31ddcf
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/8d31ddcf
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/8d31ddcf
Branch: refs/heads/HDDS-4
Commit: 8d31ddcfeb5c2e97692dd386e5bd62f433b44f8e
Parents: 16316b6
Author: Inigo Goiri <in...@apache.org>
Authored: Mon Jun 4 18:28:11 2018 -0700
Committer: Inigo Goiri <in...@apache.org>
Committed: Mon Jun 4 18:28:11 2018 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hdfs/TestDFSStripedInputStream.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/8d31ddcf/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSStripedInputStream.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSStripedInputStream.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSStripedInputStream.java
index 422746e..48ecf9a 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSStripedInputStream.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSStripedInputStream.java
@@ -105,7 +105,13 @@ public class TestDFSStripedInputStream {
CodecUtil.IO_ERASURECODE_CODEC_RS_RAWCODERS_KEY,
NativeRSRawErasureCoderFactory.CODER_NAME);
}
+ conf.set(MiniDFSCluster.HDFS_MINIDFS_BASEDIR,
+ GenericTestUtils.getRandomizedTempPath());
SimulatedFSDataset.setFactory(conf);
+ startUp();
+ }
+
+ private void startUp() throws IOException {
cluster = new MiniDFSCluster.Builder(conf).numDataNodes(
dataBlocks + parityBlocks).build();
cluster.waitActive();
@@ -326,7 +332,7 @@ public class TestDFSStripedInputStream {
if (cellMisalignPacket) {
conf.setInt(IO_FILE_BUFFER_SIZE_KEY, IO_FILE_BUFFER_SIZE_DEFAULT + 1);
tearDown();
- setup();
+ startUp();
}
DFSTestUtil.createStripedFile(cluster, filePath, null, numBlocks,
stripesPerBlock, false, ecPolicy);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org