diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java index 95dbdba..e72d700 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java @@ -343,7 +343,7 @@ public void next() throws HiveException { } else { row.add(passDownKey.get(0)); } - if ((passDownKey == null) && (reducer instanceof CommonMergeJoinOperator)) { + if ((passDownKey == null) && (reducer instanceof CommonMergeJoinOperator) && hasNext()) { passDownKey = (List) ObjectInspectorUtils.copyToStandardObject(row, reducer.getInputObjInspectors()[tag], ObjectInspectorCopyOption.WRITABLE);