From e7526606000e0b6fa72ca0b69f910383ebb1d2de Mon Sep 17 00:00:00 2001 From: Noel Kwan Date: Wed, 11 Oct 2023 13:51:53 +0800 Subject: [PATCH] assert all states finished, or all not finished --- src/stream/src/executor/backfill/no_shuffle_backfill.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/stream/src/executor/backfill/no_shuffle_backfill.rs b/src/stream/src/executor/backfill/no_shuffle_backfill.rs index 22b2ab3a3c006..5d84bc6257ca7 100644 --- a/src/stream/src/executor/backfill/no_shuffle_backfill.rs +++ b/src/stream/src/executor/backfill/no_shuffle_backfill.rs @@ -593,7 +593,7 @@ where let key: &[Datum] = &[Some(vnode.into())]; let row = state_table.get_row(key).await?; let state = Self::deserialize_backfill_state(row, pk_len); - assert_eq!(state, expected_state); + assert_eq!(state.is_finished, expected_state.is_finished); } Ok(expected_state) }