Browse Source

commit 732d54511eab79392b14da78487f98f2dc503814
Author: Krishna Ramachandran <ramach@yahoo-inc.com>
Date: Fri Dec 10 14:30:37 2010 -0800

Fix Ticket 3963156 - Mapred does not pick up viewfs as default FS when defined in core-site.xml

+++ b/YAHOO-CHANGES.txt
+ - Mapred does not pick up viewfs as default FS when defined in
+core-site.xml (Krishna Ramachandran)
+


git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-0.20-security-202@1077812 13f79535-47bb-0310-9956-ffa450edef68

Owen O'Malley 14 years ago
parent
commit
409cad8d43
1 changed files with 2 additions and 1 deletions
  1. 2 1
      src/mapred/org/apache/hadoop/mapred/JobClient.java

+ 2 - 1
src/mapred/org/apache/hadoop/mapred/JobClient.java

@@ -624,7 +624,7 @@ public class JobClient extends Configured implements MRConstants, Tool  {
     //
 
     // Create a number of filenames in the JobTracker's fs namespace
-    FileSystem fs = getFs();
+    FileSystem fs = submitJobDir.getFileSystem(job);
     LOG.debug("default FileSystem: " + fs.getUri());
     if (fs.exists(submitJobDir)) {
       throw new IOException("Not submitting job. Job directory " + submitJobDir
@@ -834,6 +834,7 @@ public class JobClient extends Configured implements MRConstants, Tool  {
           }
 
           // Create the splits for the job
+          FileSystem fs = submitJobDir.getFileSystem(jobCopy);
           LOG.debug("Creating splits at " + fs.makeQualified(submitJobDir));
           int maps = writeSplits(context, submitJobDir);
           jobCopy.setNumMapTasks(maps);