diff --git a/core/src/main/java/tachyon/Format.java b/core/src/main/java/tachyon/Format.java index 0dadf0571f2f..0866c20cb68b 100644 --- a/core/src/main/java/tachyon/Format.java +++ b/core/src/main/java/tachyon/Format.java @@ -88,9 +88,12 @@ public static void main(String[] args) throws IOException { String[] dirPaths = tachyonConf.get(tierLevelDirPath, "/mnt/ramdisk").split(","); String name = "TIER_" + level + "_DIR_PATH"; for (String dirPath : dirPaths) { - String dirWorkDataFolder = CommonUtils.concat(dirPath.trim(), workerDataFolder); - if (!formatFolder(name, dirWorkDataFolder, tachyonConf)) { - System.exit(-1); + String dirWorkerDataFolder = CommonUtils.concat(dirPath.trim(), workerDataFolder); + UnderFileSystem ufs = UnderFileSystem.get(dirWorkerDataFolder, tachyonConf); + if (ufs.exists(dirWorkerDataFolder)) { + if (!formatFolder(name, dirWorkerDataFolder, tachyonConf)) { + System.exit(-1); + } } } }