diff --git a/src/main/java/org/apache/hadoop/mapred/MesosExecutor.java b/src/main/java/org/apache/hadoop/mapred/MesosExecutor.java index f54507c..79b8b28 100644 --- a/src/main/java/org/apache/hadoop/mapred/MesosExecutor.java +++ b/src/main/java/org/apache/hadoop/mapred/MesosExecutor.java @@ -51,7 +51,7 @@ private JobConf configure(final TaskInfo task) { // Set the mapred.local directory inside the executor sandbox, so that // different TaskTrackers on the same host do not step on each other. - conf.set("mapred.local.dir", System.getProperty("user.dir") + "/mapred"); + conf.set("mapred.local.dir", System.getenv("MESOS_DIRECTORY") + "/mapred"); return conf; }