diff --git a/src/meta/src/barrier/recovery.rs b/src/meta/src/barrier/recovery.rs index 48496cf6b7271..9aaaf0ed39f6c 100644 --- a/src/meta/src/barrier/recovery.rs +++ b/src/meta/src/barrier/recovery.rs @@ -417,6 +417,8 @@ impl GlobalBarrierManagerContext { .into_iter() .collect(); + tracing::info!("all inused worker slots {:?}", all_inuse_worker_slots); + let active_worker_slots: HashSet<_> = active_nodes .current() .values() @@ -435,9 +437,11 @@ impl GlobalBarrierManagerContext { return self.resolve_graph_info().await; } - debug!("start migrate actors."); + info!("expired worker slots {:?}", expired_worker_slots); + + info!("start migrating actors."); let mut to_migrate_worker_slots = expired_worker_slots.into_iter().rev().collect_vec(); - debug!("got to migrate worker slots {:#?}", to_migrate_worker_slots); + info!("got to migrate worker slots {:#?}", to_migrate_worker_slots); let mut inuse_worker_slots: HashSet<_> = all_inuse_worker_slots .intersection(&active_worker_slots) @@ -497,10 +501,10 @@ impl GlobalBarrierManagerContext { } if !new_worker_slots.is_empty() { - debug!("new worker slots found: {:#?}", new_worker_slots); + info!("new worker slots found: {:#?}", new_worker_slots); for target_worker_slot in new_worker_slots { if let Some(from) = to_migrate_worker_slots.pop() { - debug!( + info!( "plan to migrate from worker slot {} to {}", from, target_worker_slot ); diff --git a/src/meta/src/controller/fragment.rs b/src/meta/src/controller/fragment.rs index d4dd443590507..694e109bfd54c 100644 --- a/src/meta/src/controller/fragment.rs +++ b/src/meta/src/controller/fragment.rs @@ -54,7 +54,7 @@ use sea_orm::{ ColumnTrait, DbErr, EntityTrait, JoinType, ModelTrait, PaginatorTrait, QueryFilter, QuerySelect, RelationTrait, SelectGetableTuple, Selector, TransactionTrait, Value, }; - +use tracing::info; use crate::controller::catalog::{CatalogController, CatalogControllerInner}; use crate::controller::utils::{ get_actor_dispatchers, get_fragment_mappings, rebuild_fragment_mapping_from_actors, @@ -1033,6 +1033,7 @@ impl CatalogController { let mut actor_migration_plan = HashMap::new(); for (worker, fragment) in actor_locations { if expired_workers.contains(&worker) { + info!("worker {} expired, migrating actors {:?}", worker, fragment); for (_, actors) in fragment { let worker_slot_to_actor: HashMap<_, _> = actors .iter()