Skip to content

Commit 1487714

Browse files
committed
Create the mapred system directory based first on mapreduce.jobtracker.system.dir value, and if not set the older mapred.system.dir property.
1 parent 074d9b5 commit 1487714

File tree

1 file changed

+12
-0
lines changed

1 file changed

+12
-0
lines changed

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

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,18 @@ public void setConf(Configuration conf){
6666
}else{
6767
attr = new GlusterFSXattr();
6868
}
69+
String jtSysDir = conf.get("mapreduce.jobtracker.system.dir", null);
70+
Path mapredSysDirectory = null;
71+
72+
if(jtSysDir!=null)
73+
mapredSysDirectory = new Path(jtSysDir);
74+
else{
75+
mapredSysDirectory = new Path(conf.get("mapred.system.dir", "glusterfs:///mapred/system"));
76+
}
77+
78+
if(!exists(mapredSysDirectory)){
79+
mkdirs(mapredSysDirectory);
80+
}
6981

7082
//volName=conf.get("fs.glusterfs.volname", null);
7183
//remoteGFSServer=conf.get("fs.glusterfs.server", null);

0 commit comments

Comments
 (0)