allow max_dirty_groups_heap_size to be set to 0

Signed-off-by: Richard Chien <[email protected]>
risingwavelabs · Sep 26, 2023 · abdbf10 · abdbf10
1 parent ba1eaac
commit abdbf10
Showing 1 changed file with 1 addition and 4 deletions.
diff --git 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) {