File tree Expand file tree Collapse file tree 2 files changed +6
-75
lines changed
src/main/java/org/apache/hadoop Expand file tree Collapse file tree 2 files changed +6
-75
lines changed Original file line number Diff line number Diff line change @@ -136,16 +136,19 @@ public void setConf(Configuration conf){
136
136
}
137
137
138
138
if (sameVolume (mapredSysDirectory ) && !exists (mapredSysDirectory ) ){
139
- mkdirs (mapredSysDirectory );
139
+ // mkdirs(mapredSysDirectory);
140
+ log .warn ("mapred.system.dir/mapreduce.jobtracker.system.dir does not exist: " + mapredSysDirectory );
140
141
}
141
142
//Working directory setup
142
143
143
144
Path workingDirectory = getInitialWorkingDirectory ();
144
145
if (!sameVolume (workingDirectory )){
145
146
workingDirectory = new Path ("/" );
146
147
}else if ( !exists (workingDirectory )){
147
- mkdirs (workingDirectory );
148
+ // mkdirs(workingDirectory);
149
+ log .warn ("working directory does not exist: " + workingDirectory );
148
150
}
151
+
149
152
setWorkingDirectory (workingDirectory );
150
153
151
154
@@ -291,7 +294,7 @@ public FileStatus[] listStatus(Path f) throws IOException {
291
294
}
292
295
293
296
if (localf .isDirectory () && !localf .canRead ()){
294
- throw new IOException ("Access denied : " + localf . getPath ());
297
+ throw new IOException ("Access denied : " + f . toString ());
295
298
}
296
299
297
300
File [] names = localf .listFiles ();
Load Diff This file was deleted.
You can’t perform that action at this time.
0 commit comments