Skip to content

Commit 74c96fc

Browse files
authored
perf(over window): fix over window performance degradation after risingwavelabs#11576 (risingwavelabs#12093)
Signed-off-by: Richard Chien <[email protected]>
1 parent fdaf30e commit 74c96fc

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/stream/src/executor/over_window/over_partition.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -455,7 +455,7 @@ impl<'a, S: StateStore> OverPartition<'a, S> {
455455

456456
tracing::debug!(partition=?self.this_partition_key, "loading the whole partition into cache");
457457

458-
let mut new_cache = new_empty_partition_cache();
458+
let mut new_cache = PartitionCache::new(); // shouldn't use `new_empty_partition_cache` here because we don't want sentinels
459459
let table_iter = table
460460
.iter_row_with_pk_prefix(
461461
self.this_partition_key,

0 commit comments

Comments
 (0)