diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java index b1d2f523be..3743e9af1d 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/tez/ReduceRecordSource.java @@ -234,6 +234,10 @@ public final boolean isGrouped() { @Override public boolean pushRecord() throws HiveException { + if (reducer.getDone()) { + return false; + } + if (vectorized) { return pushRecordVector(); }