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