diff --git a/be/src/exec/aggregation_node.cpp b/be/src/exec/aggregation_node.cpp
index aeaa4a57df..d479e2fddc 100644
--- a/be/src/exec/aggregation_node.cpp
+++ b/be/src/exec/aggregation_node.cpp
@@ -302,6 +302,7 @@ Status AggregationNode::get_next(RuntimeState* state, RowBatch* row_batch, bool*
                 // avoid calling finalize() duplicately with last tuple
                 // when _output_iterator don't reach end.
                 // chenhao added
+                _output_iterator.next<false>(); 
                 break;
             }
         }