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) {
