Author: edwardyoon
Date: Mon Nov 21 06:07:49 2011
New Revision: 1204359
URL: http://svn.apache.org/viewvc?rev=1204359&view=rev
Log:
Delete local files when initialization
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=1204359&r1=1204358&r2=1204359&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 06:07:49 2011
@@ -431,6 +431,7 @@ public class GroomServer implements Runn
}
systemDirectory = new Path(dir);
systemFS = systemDirectory.getFileSystem(conf);
+ deleteLocalFiles(SUBDIR);
}
justInited = false;
} catch (DiskErrorException de) {
