diff --git a/src/common/src/util/row_id.rs b/src/common/src/util/row_id.rs index 1e848deb9776d..41ff80b492bfc 100644 --- a/src/common/src/util/row_id.rs +++ b/src/common/src/util/row_id.rs @@ -302,7 +302,7 @@ impl ChangelogRowIdGenerator { } fn next_changelog_row_id_in_current_timestamp(&mut self, vnode: &VirtualNode) -> Option { - if !self.vnodes.is_set(vnode.to_index()) { + if !self.vnodes.is_set(vnode.to_index()) && *vnode != VirtualNode::ZERO { panic!("vnode {:?} not in generator", vnode); } let current_sequence = *self.vnodes_sequence.get(vnode).unwrap_or(&1);