diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManager.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManager.java index 111bfa8446c..14b04c0af34 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManager.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockManager.java @@ -1149,7 +1149,7 @@ public class TestBlockManager { } } - @Test + @Test(timeout = 60000) public void testBlockManagerMachinesArray() throws Exception { final Configuration conf = new HdfsConfiguration(); final MiniDFSCluster cluster = @@ -1160,6 +1160,8 @@ public class TestBlockManager { final Path filePath = new Path("/tmp.txt"); final long fileLen = 1L; DFSTestUtil.createFile(fs, filePath, fileLen, (short) 3, 1L); + DFSTestUtil.waitForReplication((DistributedFileSystem)fs, + filePath, (short) 3, 60000); ArrayList datanodes = cluster.getDataNodes(); assertEquals(datanodes.size(), 4); FSNamesystem ns = cluster.getNamesystem();