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 6f5830dfc0..c5b717124e 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 @@ -1504,7 +1504,7 @@ public Vertex createVertex(JobConf conf, BaseWork workUnit, Path scratchDir, if (endVertex) { vertex.addDataSink("out_"+workUnit.getName(), new DataSinkDescriptor( OutputDescriptor.create(outputKlass.getName()) - .setUserPayload(TezUtils.createUserPayloadFromConf(conf)), null, null)); + .setUserPayload(vertex.getProcessorDescriptor().getUserPayload()), null, null)); } return vertex;