svn commit: r1221622 - /incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/GroomServer.java

[edwardyoon]

Author: edwardyoon
Date: Wed Dec 21 06:05:27 2011
New Revision: 1221622

URL: http://svn.apache.org/viewvc?rev=1221622&view=rev
Log:
Fix localizeJob fails

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=1221622&r1=1221621&r2=1221622&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 
Wed Dec 21 06:05:27 2011
@@ -521,6 +521,17 @@ public class GroomServer implements Runn
 
     synchronized (rjob) {
       if (!rjob.localized) {
+        
+        FileSystem localFs = FileSystem.getLocal(conf);
+        Path jobDir = localJobFile.getParent();
+        if (localFs.exists(jobDir)){
+          localFs.delete(jobDir, true);
+          boolean b = localFs.mkdirs(jobDir);
+          if (!b)
+            throw new IOException("Not able to create job directory "
+                                  + jobDir.toString());
+        }
+        
         Path localJarFile = defaultJobConf.getLocalPath(SUBDIR + "/"
             + task.getTaskID() + "/" + "job.jar");
         systemFS.copyToLocalFile(new Path(task.getJobFile()), localJobFile);