Skip to content

Commit 2670bd2

Browse files
committed
Disable Runtime exception if working directory doesn't exist or if mapred/system directory doesn't exist.
Both directories are needed for map/reduce however they aren't required for hadoop filesystem functions which are common during cluster setup absent of the full framework.
1 parent 3a5bf4e commit 2670bd2

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/main/java/org/apache/hadoop/fs/glusterfs/GlusterVolume.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ public void setConf(Configuration conf){
137137

138138
if(sameVolume(mapredSysDirectory) && !exists(mapredSysDirectory) ){
139139
// mkdirs(mapredSysDirectory);
140-
throw new RuntimeException("Error (mapred.system.dir/mapreduce.jobtracker.system.dir) does not exist: " + mapredSysDirectory);
140+
log.warn("mapred.system.dir/mapreduce.jobtracker.system.dir does not exist: " + mapredSysDirectory);
141141
}
142142
//Working directory setup
143143

@@ -146,8 +146,9 @@ public void setConf(Configuration conf){
146146
workingDirectory = new Path("/");
147147
}else if( !exists(workingDirectory)){
148148
// mkdirs(workingDirectory);
149-
throw new RuntimeException("Error working directory does not exist: " + workingDirectory);
149+
log.warn("working directory does not exist: " + workingDirectory);
150150
}
151+
151152
setWorkingDirectory(workingDirectory);
152153

153154

0 commit comments

Comments
 (0)