diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java index 42f63bb..ea0fb4e 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/DagUtils.java @@ -191,7 +191,8 @@ private static Vertex createVertex(JobConf conf, MapWork mapWork, int seqNo, mrScratchDir.toUri().toString(), ctx); Utilities.setInputPaths(conf, inputPaths); - InputSplitInfo inputSplitInfo = MRHelpers.generateInputSplits(conf, tezDir); + InputSplitInfo inputSplitInfo = MRHelpers.generateInputSplits(conf, + new Path(tezDir, ""+seqNo)); // create the directories FileSinkOperators need Utilities.createTmpDirs(conf, mapWork);