it should be the last datum

risingwavelabs · May 19, 2023 · 7b6fb52 · 7b6fb52
1 parent 3feb4d3
commit 7b6fb52
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/stream/src/executor/backfill.rs b/src/stream/src/executor/backfill.rs
@@ -151,7 +151,7 @@ where
         let key: &[Datum] = &[Some((arbitrary_vnode as i16).into())];
         let row = self.state_table.get_row(key).await?;
         let is_finished = if let Some(row) = row
-            && let Some(is_finished) = row.datum_at(state_len -1)
+            && let Some(is_finished) = row.datum_at(state_len + 1)
         {
             println!("is_finished? {:?}", is_finished);
             is_finished.into_bool()