incubator-hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1204371 - /incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java
Date Mon, 21 Nov 2011 07:04:07 GMT
Author: edwardyoon
Date: Mon Nov 21 07:04:06 2011
New Revision: 1204371

URL: http://svn.apache.org/viewvc?rev=1204371&view=rev
Log:
Minor Refactor

Modified:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java

Modified: incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java?rev=1204371&r1=1204370&r2=1204371&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java (original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java Mon Nov 21
07:04:06 2011
@@ -247,8 +247,8 @@ public class GroomServer implements Runn
           "default"), conf.get("bsp.dns.nameserver", "default"));
     }
     // check local disk
-    checkLocalDirs(conf.getStrings("bsp.local.dir"));
-    deleteLocalFiles("groomserver");
+    checkLocalDirs(getLocalDirs());
+    deleteLocalFiles(SUBDIR);
 
     // Clear out state tables
     this.tasks.clear();
@@ -431,7 +431,6 @@ public class GroomServer implements Runn
           }
           systemDirectory = new Path(dir);
           systemFS = systemDirectory.getFileSystem(conf);
-          deleteLocalFiles(SUBDIR);
         }
         justInited = false;
       } catch (DiskErrorException de) {



Mime
View raw message