diff --git src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java index 6bc63c3..b3781e3 100644 --- src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java +++ src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java @@ -71,6 +71,7 @@ public class FSHDFSUtils extends FSUtils{ // Trying recovery boolean recovered = false; long recoveryTimeout = conf.getInt("hbase.lease.recovery.timeout", 300000); + long recoveryRetryInterval = 1000; // conf parameter passed from unit test, indicating whether fs.append() should be triggered boolean triggerAppend = conf.getBoolean(TEST_TRIGGER_DFS_APPEND, false); Exception ex = null; @@ -123,7 +124,8 @@ public class FSHDFSUtils extends FSUtils{ } } try { - Thread.sleep(1000); + Thread.sleep(recoveryRetryInterval); + recoveryRetryInterval = 20000; } catch (InterruptedException ie) { InterruptedIOException iioe = new InterruptedIOException(); iioe.initCause(ie);