diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterWalManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterWalManager.java index 27aca94..588eff7 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterWalManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterWalManager.java @@ -270,6 +270,12 @@ public class MasterWalManager { } logDirs.add(splitDir); } + } catch (IOException ioe) { + if (ioe.getMessage().contains("Filesystem closed")) { + // the underlying filesystem closed. + this.services.abort("Aborting due to closed filesystem", ioe); + throw ioe; + } } finally { if (needReleaseLock) { this.splitLogLock.unlock();