From 59fa82f97830b6f44ff38de2dd2d283be7f85e43 Mon Sep 17 00:00:00 2001 From: xxhZs <1060434431@qq.com> Date: Fri, 26 Sep 2025 12:49:13 +0800 Subject: [PATCH] fix error --- src/common/src/util/row_id.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);