From ca48be1d17d0ca1de01d7b6489ed82acf5a48033 Mon Sep 17 00:00:00 2001 From: Richard Chien Date: Wed, 23 Oct 2024 21:11:10 +0800 Subject: [PATCH] remove table assertion on prefix_hint_len Signed-off-by: Richard Chien --- src/stream/src/common/table/state_table.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/stream/src/common/table/state_table.rs b/src/stream/src/common/table/state_table.rs index 3ada0afd71625..0186991da8532 100644 --- a/src/stream/src/common/table/state_table.rs +++ b/src/stream/src/common/table/state_table.rs @@ -643,16 +643,16 @@ where pub async fn get_encoded_row(&self, pk: impl Row) -> StreamExecutorResult> { assert!(pk.len() <= self.pk_indices.len()); - if self.prefix_hint_len != 0 { - debug_assert_eq!(self.prefix_hint_len, pk.len()); - } - let serialized_pk = serialize_pk_with_vnode(&pk, &self.pk_serde, self.compute_vnode_by_pk(&pk)); let prefix_hint = if self.prefix_hint_len != 0 && self.prefix_hint_len == pk.len() { Some(serialized_pk.slice(VirtualNode::SIZE..)) } else { + #[cfg(debug_assertions)] + if self.prefix_hint_len != 0 { + warn!("prefix_hint_len is not equal to pk.len(), may not be able to utilize bloom filter"); + } None };