diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java index c77e081..5a784d3 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java @@ -158,8 +158,6 @@ void init(JobConf jconf, ProcessorContext processorContext, MRTaskReporter mrRep if (mergeWorkList != null) { MapOperator mergeMapOp = null; for (MapWork mergeMapWork : mergeWorkList) { - processorContext.waitForAnyInputReady(Collections.singletonList((Input) (inputs - .get(mergeMapWork.getName())))); if (mergeMapWork.getVectorMode()) { mergeMapOp = new VectorMapOperator(); } else { @@ -196,6 +194,7 @@ void init(JobConf jconf, ProcessorContext processorContext, MRTaskReporter mrRep mapOp.setExecContext(execContext); mapOp.initializeLocalWork(jconf); + processorContext.waitForAllInputsReady(Collections.unmodifiableCollection(inputs.values())); initializeMapRecordSources(); mapOp.initialize(jconf, null); if ((mergeMapOpList != null) && mergeMapOpList.isEmpty() == false) {