diff --git a/src/main/java/org/apache/hadoop/fs/glusterfs/GlusterVolume.java b/src/main/java/org/apache/hadoop/fs/glusterfs/GlusterVolume.java index abe43fbc..e803efc4 100644 --- a/src/main/java/org/apache/hadoop/fs/glusterfs/GlusterVolume.java +++ b/src/main/java/org/apache/hadoop/fs/glusterfs/GlusterVolume.java @@ -135,7 +135,9 @@ public void setConf(Configuration conf){ } if(sameVolume(mapredSysDirectory) && !exists(mapredSysDirectory) ){ - mkdirs(mapredSysDirectory); + //mkdirs(mapredSysDirectory); + log.error("Exception loading glusterfs plugin. mapred.system.dir defined as: " + mapredSysDirectory + " but does not exit."); + throw new RuntimeException("mapred.system.dir: " + mapredSysDirectory + " does not exist."); } //Working directory setup