diff --git a/src/stream/src/executor/backfill.rs b/src/stream/src/executor/backfill.rs index eddccb992f402..d9c2e6d8ad0bd 100644 --- a/src/stream/src/executor/backfill.rs +++ b/src/stream/src/executor/backfill.rs @@ -154,8 +154,11 @@ where && let Some(is_finished) = row.datum_at(state_len + 1) { println!("is_finished? {:?}", is_finished); + println!("row: {:?}", row); is_finished.into_bool() } else { + println!("not finished"); + println!("row: {:?}", row); false };