diff --git a/src/stream/src/executor/backfill.rs b/src/stream/src/executor/backfill.rs index eddccb992f402..b878caf0b6923 100644 --- a/src/stream/src/executor/backfill.rs +++ b/src/stream/src/executor/backfill.rs @@ -150,12 +150,14 @@ where .expect("All executors should have vnode"); let key: &[Datum] = &[Some((arbitrary_vnode as i16).into())]; let row = self.state_table.get_row(key).await?; + println!("row: {:?}", row); let is_finished = if let Some(row) = row && let Some(is_finished) = row.datum_at(state_len + 1) { println!("is_finished? {:?}", is_finished); is_finished.into_bool() } else { + println!("not finished"); false };