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 ea0fb4e..c342801 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 @@ -272,6 +272,9 @@ private static Vertex createVertex(JobConf conf, ReduceWork reduceWork, int seqN // create the directories FileSinkOperators need Utilities.createTmpDirs(conf, reduceWork); + // Call once here, will be updated when we find edges + MultiStageMRConfToTezTranslator.translateVertexConfToTez(conf, null); + // create the vertex Vertex reducer = new Vertex("Reducer "+seqNo, new ProcessorDescriptor(ReduceProcessor.class.getName(),