From 76b52067e6cf6d1e97cb2aa533ed46de97771e83 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Fri, 19 May 2023 22:04:06 +0800 Subject: [PATCH] add some debug --- src/stream/src/executor/backfill.rs | 2 ++ 1 file changed, 2 insertions(+) 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 };