Skip to content

Commit

Permalink
perf(over window): fix over window performance degradation after risi…
Browse files Browse the repository at this point in the history
…ngwavelabs#11576 (risingwavelabs#12093)

Signed-off-by: Richard Chien <stdrc@outlook.com>
  • Loading branch information
stdrc committed Sep 5, 2023
1 parent fdaf30e commit 74c96fc
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/stream/src/executor/over_window/over_partition.rs
Original file line number Diff line number Diff line change
Expand Up @@ -455,7 +455,7 @@ impl<'a, S: StateStore> OverPartition<'a, S> {

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

let mut new_cache = new_empty_partition_cache();
let mut new_cache = PartitionCache::new(); // shouldn't use `new_empty_partition_cache` here because we don't want sentinels
let table_iter = table
.iter_row_with_pk_prefix(
self.this_partition_key,
Expand Down

0 comments on commit 74c96fc

Please sign in to comment.