From 00d43edc4d52496ee4aef922b230148f776b9865 Mon Sep 17 00:00:00 2001 From: Yuhao Su Date: Mon, 17 Jun 2024 14:26:00 -0500 Subject: [PATCH] revert fix --- src/meta/src/controller/fragment.rs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/meta/src/controller/fragment.rs b/src/meta/src/controller/fragment.rs index fb8810071f162..5320d555b94f9 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, I32Array)> = Actor::find() + let actor_info: Vec<(ActorId, WorkerId, FragmentId, i32, Vec)> = Actor::find() .select_only() .column(actor::Column::ActorId) .column(actor::Column::WorkerId) @@ -880,7 +880,6 @@ 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();