unit tests timeout

Author: hfutatzhanghb

hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDecommission.java

@@ -435,7 +435,7 @@ private void testDecommission(int numNamenodes, int numDatanodes)
   /**
    * Test that over-replicated blocks are deleted on recommission.
    */
-  @Test(timeout=120000)
+  @Test(timeout=360000)
   public void testRecommission() throws Exception {
     final int numDatanodes = 6;
     try {
@@ -624,7 +624,7 @@ public void testHostsFile(int numNameNodes) throws IOException,
     }
   }
 
-  @Test(timeout=120000)
+  @Test(timeout=360000)
   public void testDecommissionWithOpenfile()
       throws IOException, InterruptedException {
     LOG.info("Starting test testDecommissionWithOpenfile");
@@ -676,7 +676,7 @@ public void testDecommissionWithOpenfile()
     fdos.close();
   }
 
-  @Test(timeout = 20000)
+  @Test(timeout = 360000)
   public void testDecommissionWithUnknownBlock() throws IOException {
     startCluster(1, 3);
 
@@ -795,7 +795,7 @@ public Boolean get() {
     }
   }
 
-  @Test(timeout=180000)
+  @Test(timeout=360000)
   public void testDecommissionWithOpenfileReporting()
       throws Exception {
     LOG.info("Starting test testDecommissionWithOpenfileReporting");
@@ -1005,7 +1005,7 @@ public void testDecommissionWithOpenFileAndBlockRecovery()
     assertEquals(dfs.getFileStatus(file).getLen(), writtenBytes);
   }
 
-  @Test(timeout=120000)
+  @Test(timeout=360000)
   public void testCloseWhileDecommission() throws IOException,
       ExecutionException, InterruptedException {
     LOG.info("Starting test testCloseWhileDecommission");
@@ -1064,7 +1064,7 @@ public void testCloseWhileDecommission() throws IOException,
    * to the IBR, all three nodes dn1/dn2/dn3 enter Decommissioning and then the
    * DN reports the IBR.
    */
-  @Test(timeout=120000)
+  @Test(timeout=360000)
   public void testAllocAndIBRWhileDecommission() throws IOException {
     LOG.info("Starting test testAllocAndIBRWhileDecommission");
     getConf().setLong(DFSConfigKeys.DFS_BLOCKREPORT_INTERVAL_MSEC_KEY,
@@ -1314,7 +1314,7 @@ public Boolean get() {
     }, 500, 5000);
   }
 
-  @Test(timeout=120000)
+  @Test(timeout=360000)
   public void testBlocksPerInterval() throws Exception {
     GenericTestUtils.setLogLevel(
         LoggerFactory.getLogger(DatanodeAdminManager.class), Level.TRACE);
@@ -1369,7 +1369,7 @@ private void doDecomCheck(DatanodeManager datanodeManager,
   /**
    * Test DatanodeAdminManager#monitor can swallow any exceptions by default.
    */
-  @Test(timeout=120000)
+  @Test(timeout=360000)
   public void testPendingNodeButDecommissioned() throws Exception {
     // Only allow one node to be decom'd at a time
     getConf().setInt(
@@ -1416,7 +1416,7 @@ public void testPendingNodeButDecommissioned() throws Exception {
     }
   }
 
-  @Test(timeout=120000)
+  @Test(timeout=360000)
   public void testPendingNodes() throws Exception {
     GenericTestUtils.setLogLevel(
         LoggerFactory.getLogger(DatanodeAdminManager.class), Level.TRACE);
@@ -1685,7 +1685,7 @@ public Boolean get() {
    * Force the tracked nodes set to be filled with nodes lost while decommissioning,
    * then decommission healthy nodes & validate they are decommissioned eventually.
    */
-  @Test(timeout = 120000)
+  @Test(timeout = 360000)
   public void testRequeueUnhealthyDecommissioningNodes() throws Exception {
     // Create a MiniDFSCluster with 3 live datanode in AdminState=NORMAL and
     // 2 dead datanodes in AdminState=DECOMMISSION_INPROGRESS and a file
@@ -1911,7 +1911,7 @@ private void createClusterWithDeadNodesDecommissionInProgress(final int numLiveN
   under-replicated block can be replicated to sufficient datanodes & the decommissioning
   node can be decommissioned.
    */
-  @Test(timeout = 120000)
+  @Test(timeout = 300000)
   public void testDeleteCorruptReplicaForUnderReplicatedBlock() throws Exception {
     // Constants
     final Path file = new Path("/test-file");

hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestRollingUpgrade.java

@@ -169,7 +169,7 @@ private static Configuration setConf(Configuration conf, File dir,
     return conf;
   }
 
-  @Test (timeout = 30000)
+  @Test (timeout = 300000)
   public void testRollingUpgradeWithQJM() throws Exception {
     String nnDirPrefix = MiniDFSCluster.getBaseDirectory() + "/nn/";
     final File nn1Dir = new File(nnDirPrefix + "image1");
@@ -601,7 +601,7 @@ public void testCheckpointWithMultipleNN() throws IOException, InterruptedExcept
     testCheckpoint(3);
   }
 
-  @Test(timeout = 60000)
+  @Test(timeout = 300000)
   public void testRollBackImage() throws Exception {
     final Configuration conf = new HdfsConfiguration();
     conf.setInt(DFSConfigKeys.DFS_NAMENODE_CHECKPOINT_TXNS_KEY, 10);