diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java index ea2e1fdb65..aa65dba657 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/MapRecordProcessor.java @@ -411,7 +411,7 @@ private KeyValueReader getKeyValueReader(Collection keyValueRead private Operator getFinalOp(Operator mergeMapOp) { for (Operator childOp : mergeMapOp.getChildOperators()) { - if ((childOp.getChildOperators() == null) || (childOp.getChildOperators().isEmpty())) { + if (childOp instanceof TezDummyStoreOperator || (childOp.getChildOperators() == null) || (childOp.getChildOperators().isEmpty())) { return childOp; } else { return getFinalOp(childOp);