|
@@ -146,6 +146,7 @@ public class TestComputeInvalidateWork {
|
|
|
// Create a file and shutdown the DNs, which populates InvalidateBlocks
|
|
|
DFSTestUtil.createFile(dfs, path, dfs.getDefaultBlockSize(),
|
|
|
(short) NUM_OF_DATANODES, 0xED0ED0);
|
|
|
+ DFSTestUtil.waitForReplication(dfs, path, (short) NUM_OF_DATANODES, 12000);
|
|
|
for (DataNode dn : cluster.getDataNodes()) {
|
|
|
dn.shutdown();
|
|
|
}
|