actually recover row count

risingwavelabs · Aug 15, 2024 · 55aa486 · 55aa486
1 parent 47c3fcc
commit 55aa486
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/stream/src/executor/approx_percentile/global_state.rs b/src/stream/src/executor/approx_percentile/global_state.rs
@@ -67,6 +67,7 @@ impl<S: StateStore> GlobalApproxPercentileState<S> {
         // Refill row_count
         let row_count_state = self.get_row_count_state().await?;
         let row_count = Self::decode_row_count(&row_count_state)?;
+        self.row_count = row_count;
         tracing::debug!(?row_count, "recovered row_count");
 
         // Refill cache