diff --git src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java index 0f1ea14..b104634 100644 --- src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java +++ src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java @@ -132,8 +132,9 @@ public class FSHDFSUtils extends FSUtils{ iioe.initCause(ie); throw iioe; } - // we keep original behavior without retrying lease recovery - break; + if (!conf.getBoolean("hbase.lease.recovery.required", false)) { + break; + } } LOG.info("Finished lease recovery attempt for " + p); }