diff --git a/src/stream/src/executor/hash_agg.rs b/src/stream/src/executor/hash_agg.rs
index c7b1339c11a6..a8a124d30a66 100644
--- a/src/stream/src/executor/hash_agg.rs
+++ b/src/stream/src/executor/hash_agg.rs
@@ -650,10 +650,7 @@ impl<K: HashKey, S: StateStore> HashAggExecutor<K, S> {
                 Message::Chunk(chunk) => {
                     Self::apply_chunk(&mut this, &mut vars, chunk).await?;
 
-                    if this.max_dirty_groups_heap_size > 0
-                        && vars.dirty_groups.estimated_heap_size()
-                            >= this.max_dirty_groups_heap_size
-                    {
+                    if vars.dirty_groups.estimated_heap_size() >= this.max_dirty_groups_heap_size {
                         // flush dirty groups if heap size is too large, to better prevent from OOM
                         #[for_await]
                         for chunk in Self::flush_data(&mut this, &mut vars) {