From ecb6ba3249d9f8d319b30b99417cf54a4ad1ea58 Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Sat, 20 May 2023 01:39:36 +0800 Subject: [PATCH] add more tracing --- 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 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);