Check if the data directory exists before trying to format.

Alluxio · Apr 11, 2015 · 5690872 · 5690872
1 parent 3552655
commit 5690872
Showing 1 changed file with 6 additions and 3 deletions.
diff --git 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);
+            }
           }
         }
       }