diff --git a/src/stream/src/executor/backfill.rs b/src/stream/src/executor/backfill.rs index 50a914678f89d..5eb50128e158b 100644 --- a/src/stream/src/executor/backfill.rs +++ b/src/stream/src/executor/backfill.rs @@ -566,6 +566,7 @@ where if old_state[1..] != current_partial_state[1..] { vnodes.iter_ones().for_each(|vnode| { let datum = Some((vnode as i16).into()); + println!("datum: {:?}", datum); // fill the state current_partial_state[0] = datum.clone(); old_state[0] = datum; @@ -585,6 +586,7 @@ where // No existing state, create a new entry. vnodes.iter_ones().for_each(|vnode| { let datum = Some((vnode as i16).into()); + println!("datum: {:?}", datum); // fill the state current_partial_state[0] = datum; println!("Inserting new_row: {:?}", current_partial_state);