[20/50] [abbrv] hadoop git commit: HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. Contributed by Rakesh R

2016-10-21 Thread aengineer 
HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. 
Contributed by Rakesh R


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d26a1bb9
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d26a1bb9
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d26a1bb9

Branch: refs/heads/HDFS-7240
Commit: d26a1bb9d60f50763887d66399579bac7ca81982
Parents: c023c74
Author: Kai Zheng 
Authored: Tue Oct 18 14:51:08 2016 +0600
Committer: Kai Zheng 
Committed: Tue Oct 18 14:51:08 2016 +0600

--
 .../hadoop/hdfs/server/mover/TestStorageMover.java | 17 ++---
 1 file changed, 10 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/d26a1bb9/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
index 92a70a0..1b5bd81 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
@@ -613,8 +613,10 @@ public class TestStorageMover {
   }
 
   private void waitForAllReplicas(int expectedReplicaNum, Path file,
-  DistributedFileSystem dfs) throws Exception {
-for (int i = 0; i < 5; i++) {
+  DistributedFileSystem dfs, int retryCount) throws Exception {
+LOG.info("Waiting for replicas count " + expectedReplicaNum
++ ", file name: " + file);
+for (int i = 0; i < retryCount; i++) {
   LocatedBlocks lbs = dfs.getClient().getLocatedBlocks(file.toString(), 0,
   BLOCK_SIZE);
   LocatedBlock lb = lbs.get(0);
@@ -664,7 +666,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.hot, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the DISK volume to full
@@ -679,16 +681,17 @@ public class TestStorageMover {
   final Replication r = test.getReplication(file0);
   final short newReplication = (short) 5;
   test.dfs.setReplication(file0, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, file0, test.dfs, 10);
   test.verifyReplication(file0, r.disk, newReplication - r.disk);
 
   // test creating a cold file and then increase replication
   final Path p = new Path(pathPolicyMap.cold, "foo");
   DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
+  waitForAllReplicas(replication, p, test.dfs, 10);
   test.verifyReplication(p, 0, replication);
 
   test.dfs.setReplication(p, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, p, test.dfs, 10);
   test.verifyReplication(p, 0, newReplication);
 
   //test move a hot file to warm
@@ -722,7 +725,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.cold, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the ARCHIVE volume to full
@@ -739,7 +742,7 @@ public class TestStorageMover {
 
 final short newReplication = (short) 5;
 test.dfs.setReplication(file0, newReplication);
-Thread.sleep(1);
+waitForAllReplicas(r.archive, file0, test.dfs, 10);
 
 test.verifyReplication(file0, 0, r.archive);
   }


-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

[42/50] [abbrv] hadoop git commit: HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. Contributed by Rakesh R

2016-10-18 Thread sjlee 
HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. 
Contributed by Rakesh R


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d26a1bb9
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d26a1bb9
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d26a1bb9

Branch: refs/heads/HADOOP-13070
Commit: d26a1bb9d60f50763887d66399579bac7ca81982
Parents: c023c74
Author: Kai Zheng 
Authored: Tue Oct 18 14:51:08 2016 +0600
Committer: Kai Zheng 
Committed: Tue Oct 18 14:51:08 2016 +0600

--
 .../hadoop/hdfs/server/mover/TestStorageMover.java | 17 ++---
 1 file changed, 10 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/d26a1bb9/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
index 92a70a0..1b5bd81 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
@@ -613,8 +613,10 @@ public class TestStorageMover {
   }
 
   private void waitForAllReplicas(int expectedReplicaNum, Path file,
-  DistributedFileSystem dfs) throws Exception {
-for (int i = 0; i < 5; i++) {
+  DistributedFileSystem dfs, int retryCount) throws Exception {
+LOG.info("Waiting for replicas count " + expectedReplicaNum
++ ", file name: " + file);
+for (int i = 0; i < retryCount; i++) {
   LocatedBlocks lbs = dfs.getClient().getLocatedBlocks(file.toString(), 0,
   BLOCK_SIZE);
   LocatedBlock lb = lbs.get(0);
@@ -664,7 +666,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.hot, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the DISK volume to full
@@ -679,16 +681,17 @@ public class TestStorageMover {
   final Replication r = test.getReplication(file0);
   final short newReplication = (short) 5;
   test.dfs.setReplication(file0, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, file0, test.dfs, 10);
   test.verifyReplication(file0, r.disk, newReplication - r.disk);
 
   // test creating a cold file and then increase replication
   final Path p = new Path(pathPolicyMap.cold, "foo");
   DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
+  waitForAllReplicas(replication, p, test.dfs, 10);
   test.verifyReplication(p, 0, replication);
 
   test.dfs.setReplication(p, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, p, test.dfs, 10);
   test.verifyReplication(p, 0, newReplication);
 
   //test move a hot file to warm
@@ -722,7 +725,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.cold, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the ARCHIVE volume to full
@@ -739,7 +742,7 @@ public class TestStorageMover {
 
 final short newReplication = (short) 5;
 test.dfs.setReplication(file0, newReplication);
-Thread.sleep(1);
+waitForAllReplicas(r.archive, file0, test.dfs, 10);
 
 test.verifyReplication(file0, 0, r.archive);
   }


-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

hadoop git commit: HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. Contributed by Rakesh R

2016-10-18 Thread drankye 
Repository: hadoop
Updated Branches:
  refs/heads/branch-2.8 ae972dd08 -> d26e11f30


HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. 
Contributed by Rakesh R


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d26e11f3
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d26e11f3
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d26e11f3

Branch: refs/heads/branch-2.8
Commit: d26e11f30eb15b20ea9f71a0e22d5675d3b04b87
Parents: ae972dd
Author: Kai Zheng 
Authored: Tue Oct 18 15:09:25 2016 +0600
Committer: Kai Zheng 
Committed: Tue Oct 18 15:09:25 2016 +0600

--
 .../hadoop/hdfs/server/mover/TestStorageMover.java | 17 ++---
 1 file changed, 10 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/d26e11f3/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
index 549dbc8..26032cf 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
@@ -641,8 +641,10 @@ public class TestStorageMover {
   }
 
   private void waitForAllReplicas(int expectedReplicaNum, Path file,
-  DistributedFileSystem dfs) throws Exception {
-for (int i = 0; i < 5; i++) {
+  DistributedFileSystem dfs, int retryCount) throws Exception {
+LOG.info("Waiting for replicas count " + expectedReplicaNum
++ ", file name: " + file);
+for (int i = 0; i < retryCount; i++) {
   LocatedBlocks lbs = dfs.getClient().getLocatedBlocks(file.toString(), 0,
   BLOCK_SIZE);
   LocatedBlock lb = lbs.get(0);
@@ -692,7 +694,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.hot, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the DISK volume to full
@@ -707,16 +709,17 @@ public class TestStorageMover {
   final Replication r = test.getReplication(file0);
   final short newReplication = (short) 5;
   test.dfs.setReplication(file0, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, file0, test.dfs, 10);
   test.verifyReplication(file0, r.disk, newReplication - r.disk);
 
   // test creating a cold file and then increase replication
   final Path p = new Path(pathPolicyMap.cold, "foo");
   DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
+  waitForAllReplicas(replication, p, test.dfs, 10);
   test.verifyReplication(p, 0, replication);
 
   test.dfs.setReplication(p, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, p, test.dfs, 10);
   test.verifyReplication(p, 0, newReplication);
 
   //test move a hot file to warm
@@ -750,7 +753,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.cold, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the ARCHIVE volume to full
@@ -767,7 +770,7 @@ public class TestStorageMover {
 
 final short newReplication = (short) 5;
 test.dfs.setReplication(file0, newReplication);
-Thread.sleep(1);
+waitForAllReplicas(r.archive, file0, test.dfs, 10);
 
 test.verifyReplication(file0, 0, r.archive);
   }


-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

hadoop git commit: HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. Contributed by Rakesh R

2016-10-18 Thread drankye 
Repository: hadoop
Updated Branches:
  refs/heads/branch-2 b2618685f -> 3972bb3bb


HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. 
Contributed by Rakesh R


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/3972bb3b
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/3972bb3b
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/3972bb3b

Branch: refs/heads/branch-2
Commit: 3972bb3bbabacc42b738590cd8815d216c5cbdd4
Parents: b261868
Author: Kai Zheng 
Authored: Tue Oct 18 15:08:15 2016 +0600
Committer: Kai Zheng 
Committed: Tue Oct 18 15:08:15 2016 +0600

--
 .../hadoop/hdfs/server/mover/TestStorageMover.java | 17 ++---
 1 file changed, 10 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/3972bb3b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
index 549dbc8..26032cf 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
@@ -641,8 +641,10 @@ public class TestStorageMover {
   }
 
   private void waitForAllReplicas(int expectedReplicaNum, Path file,
-  DistributedFileSystem dfs) throws Exception {
-for (int i = 0; i < 5; i++) {
+  DistributedFileSystem dfs, int retryCount) throws Exception {
+LOG.info("Waiting for replicas count " + expectedReplicaNum
++ ", file name: " + file);
+for (int i = 0; i < retryCount; i++) {
   LocatedBlocks lbs = dfs.getClient().getLocatedBlocks(file.toString(), 0,
   BLOCK_SIZE);
   LocatedBlock lb = lbs.get(0);
@@ -692,7 +694,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.hot, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the DISK volume to full
@@ -707,16 +709,17 @@ public class TestStorageMover {
   final Replication r = test.getReplication(file0);
   final short newReplication = (short) 5;
   test.dfs.setReplication(file0, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, file0, test.dfs, 10);
   test.verifyReplication(file0, r.disk, newReplication - r.disk);
 
   // test creating a cold file and then increase replication
   final Path p = new Path(pathPolicyMap.cold, "foo");
   DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
+  waitForAllReplicas(replication, p, test.dfs, 10);
   test.verifyReplication(p, 0, replication);
 
   test.dfs.setReplication(p, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, p, test.dfs, 10);
   test.verifyReplication(p, 0, newReplication);
 
   //test move a hot file to warm
@@ -750,7 +753,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.cold, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the ARCHIVE volume to full
@@ -767,7 +770,7 @@ public class TestStorageMover {
 
 final short newReplication = (short) 5;
 test.dfs.setReplication(file0, newReplication);
-Thread.sleep(1);
+waitForAllReplicas(r.archive, file0, test.dfs, 10);
 
 test.verifyReplication(file0, 0, r.archive);
   }


-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

hadoop git commit: HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. Contributed by Rakesh R

2016-10-18 Thread drankye 
Repository: hadoop
Updated Branches:
  refs/heads/trunk c023c7488 -> d26a1bb9d


HDFS-10920. TestStorageMover#testNoSpaceDisk is failing intermittently. 
Contributed by Rakesh R


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d26a1bb9
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d26a1bb9
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d26a1bb9

Branch: refs/heads/trunk
Commit: d26a1bb9d60f50763887d66399579bac7ca81982
Parents: c023c74
Author: Kai Zheng 
Authored: Tue Oct 18 14:51:08 2016 +0600
Committer: Kai Zheng 
Committed: Tue Oct 18 14:51:08 2016 +0600

--
 .../hadoop/hdfs/server/mover/TestStorageMover.java | 17 ++---
 1 file changed, 10 insertions(+), 7 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hadoop/blob/d26a1bb9/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
--
diff --git 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
index 92a70a0..1b5bd81 100644
--- 
a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
+++ 
b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/mover/TestStorageMover.java
@@ -613,8 +613,10 @@ public class TestStorageMover {
   }
 
   private void waitForAllReplicas(int expectedReplicaNum, Path file,
-  DistributedFileSystem dfs) throws Exception {
-for (int i = 0; i < 5; i++) {
+  DistributedFileSystem dfs, int retryCount) throws Exception {
+LOG.info("Waiting for replicas count " + expectedReplicaNum
++ ", file name: " + file);
+for (int i = 0; i < retryCount; i++) {
   LocatedBlocks lbs = dfs.getClient().getLocatedBlocks(file.toString(), 0,
   BLOCK_SIZE);
   LocatedBlock lb = lbs.get(0);
@@ -664,7 +666,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.hot, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the DISK volume to full
@@ -679,16 +681,17 @@ public class TestStorageMover {
   final Replication r = test.getReplication(file0);
   final short newReplication = (short) 5;
   test.dfs.setReplication(file0, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, file0, test.dfs, 10);
   test.verifyReplication(file0, r.disk, newReplication - r.disk);
 
   // test creating a cold file and then increase replication
   final Path p = new Path(pathPolicyMap.cold, "foo");
   DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
+  waitForAllReplicas(replication, p, test.dfs, 10);
   test.verifyReplication(p, 0, replication);
 
   test.dfs.setReplication(p, newReplication);
-  Thread.sleep(1);
+  waitForAllReplicas(newReplication, p, test.dfs, 10);
   test.verifyReplication(p, 0, newReplication);
 
   //test move a hot file to warm
@@ -722,7 +725,7 @@ public class TestStorageMover {
   for (int i = 0; i < 2; i++) {
 final Path p = new Path(pathPolicyMap.cold, "file" + i);
 DFSTestUtil.createFile(test.dfs, p, BLOCK_SIZE, replication, 0L);
-waitForAllReplicas(replication, p, test.dfs);
+waitForAllReplicas(replication, p, test.dfs, 10);
   }
 
   // set all the ARCHIVE volume to full
@@ -739,7 +742,7 @@ public class TestStorageMover {
 
 final short newReplication = (short) 5;
 test.dfs.setReplication(file0, newReplication);
-Thread.sleep(1);
+waitForAllReplicas(r.archive, file0, test.dfs, 10);
 
 test.verifyReplication(file0, 0, r.archive);
   }


-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org