From d555b5c11b6c540abe356454f3409b30a8fb43a6 Mon Sep 17 00:00:00 2001 From: Yuhao Su <31772373+yuhao-su@users.noreply.github.com> Date: Mon, 17 Jun 2024 14:21:59 -0500 Subject: [PATCH] fix(migration): use correct type I32Array instead of Vec (#17282) --- src/meta/src/controller/fragment.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/meta/src/controller/fragment.rs b/src/meta/src/controller/fragment.rs index 5320d555b94f..fb8810071f16 100644 --- a/src/meta/src/controller/fragment.rs +++ b/src/meta/src/controller/fragment.rs @@ -864,7 +864,7 @@ impl CatalogController { /// collected pub async fn load_all_actors(&self) -> MetaResult { let inner = self.inner.read().await; - let actor_info: Vec<(ActorId, WorkerId, FragmentId, i32, Vec)> = Actor::find() + let actor_info: Vec<(ActorId, WorkerId, FragmentId, i32, I32Array)> = Actor::find() .select_only() .column(actor::Column::ActorId) .column(actor::Column::WorkerId) @@ -880,6 +880,7 @@ impl CatalogController { let mut fragment_infos = HashMap::new(); for (actor_id, worker_id, fragment_id, type_mask, state_table_ids) in actor_info { + let state_table_ids = state_table_ids.into_inner(); match fragment_infos.entry(fragment_id as crate::model::FragmentId) { Entry::Occupied(mut entry) => { let info: &mut InflightFragmentInfo = entry.get_mut();