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 aw...@apache.org on 2015/07/30 03:27:35 UTC
[05/14] hadoop git commit: HDFS-8834. TestReplication is not valid
after HDFS-6482. (Contributed by Lei Xu)
HDFS-8834. TestReplication is not valid after HDFS-6482. (Contributed by Lei Xu)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/f4f1b8b2
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f4f1b8b2
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f4f1b8b2
Branch: refs/heads/HADOOP-12111
Commit: f4f1b8b267703b8bebab06e17e69a4a4de611592
Parents: 975e138
Author: Lei Xu <le...@cloudera.com>
Authored: Tue Jul 28 16:55:51 2015 -0700
Committer: Lei Xu <le...@cloudera.com>
Committed: Tue Jul 28 23:39:26 2015 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hdfs/TestReplication.java | 26 +++++++++++++++++++-
1 file changed, 25 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/f4f1b8b2/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReplication.java
----------------------------------------------------------------------
diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReplication.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReplication.java
index b702da0..2139df9 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReplication.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestReplication.java
@@ -18,6 +18,8 @@
package org.apache.hadoop.hdfs;
import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
import java.io.File;
@@ -25,6 +27,10 @@ import java.io.IOException;
import java.io.OutputStream;
import java.io.RandomAccessFile;
import java.net.InetSocketAddress;
+import java.nio.file.FileVisitResult;
+import java.nio.file.Files;
+import java.nio.file.SimpleFileVisitor;
+import java.nio.file.attribute.BasicFileAttributes;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
@@ -505,12 +511,28 @@ public class TestReplication {
if (data_dir.listFiles().length == 0) {
nonParticipatedNodeDirs.add(data_dir);
} else {
+ assertNull("participatedNodeDirs has already been set.",
+ participatedNodeDirs);
participatedNodeDirs = data_dir;
}
}
+ assertEquals(2, nonParticipatedNodeDirs.size());
String blockFile = null;
- File[] listFiles = participatedNodeDirs.listFiles();
+ final List<File> listFiles = new ArrayList<>();
+ Files.walkFileTree(participatedNodeDirs.toPath(),
+ new SimpleFileVisitor<java.nio.file.Path>() {
+ @Override
+ public FileVisitResult visitFile(
+ java.nio.file.Path file, BasicFileAttributes attrs)
+ throws IOException {
+ listFiles.add(file.toFile());
+ return FileVisitResult.CONTINUE;
+ }
+ }
+ );
+ assertFalse(listFiles.isEmpty());
+ int numReplicaCreated = 0;
for (File file : listFiles) {
if (file.getName().startsWith(Block.BLOCK_FILE_PREFIX)
&& !file.getName().endsWith("meta")) {
@@ -519,10 +541,12 @@ public class TestReplication {
file1.mkdirs();
new File(file1, blockFile).createNewFile();
new File(file1, blockFile + "_1000.meta").createNewFile();
+ numReplicaCreated++;
}
break;
}
}
+ assertEquals(2, numReplicaCreated);
fs.setReplication(new Path("/test"), (short) 3);
cluster.restartDataNodes(); // Lets detect all DNs about dummy copied