From 47f6a7ad84f28f2c749447b7d649a213e52546c3 Mon Sep 17 00:00:00 2001 From: Paul Masurel Date: Tue, 19 Dec 2023 15:16:43 +0900 Subject: [PATCH] debug info --- quickwit/quickwit-control-plane/src/control_plane.rs | 1 + .../quickwit-control-plane/src/indexing_scheduler/mod.rs | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/quickwit/quickwit-control-plane/src/control_plane.rs b/quickwit/quickwit-control-plane/src/control_plane.rs index eb3866b509b..4c3441ee4bf 100644 --- a/quickwit/quickwit-control-plane/src/control_plane.rs +++ b/quickwit/quickwit-control-plane/src/control_plane.rs @@ -225,6 +225,7 @@ impl Handler for ControlPlane { _message: ControlPlanLoop, ctx: &ActorContext, ) -> Result<(), ActorExitStatus> { + self.indexing_scheduler.schedule_indexing_plan_if_needed(&self.model); self.indexing_scheduler.control_running_plan(&self.model); ctx.schedule_self_msg(CONTROL_PLAN_LOOP_INTERVAL, ControlPlanLoop) .await; diff --git a/quickwit/quickwit-control-plane/src/indexing_scheduler/mod.rs b/quickwit/quickwit-control-plane/src/indexing_scheduler/mod.rs index 09adddb7abb..a78e55a20c8 100644 --- a/quickwit/quickwit-control-plane/src/indexing_scheduler/mod.rs +++ b/quickwit/quickwit-control-plane/src/indexing_scheduler/mod.rs @@ -222,7 +222,7 @@ impl IndexingScheduler { return; } } - self.apply_physical_indexing_plan(&mut indexers, new_physical_plan); + // self.apply_physical_indexing_plan(&mut indexers, new_physical_plan); self.state.num_schedule_indexing_plan += 1; } @@ -258,6 +258,9 @@ impl IndexingScheduler { }) .collect(); + debug!(running_plan=?running_indexing_tasks_by_node_id, "running plan"); + debug!(last_applied_plan=?last_applied_plan.indexing_tasks_per_indexer(), "last applied plan"); + let indexing_plans_diff = get_indexing_plans_diff( &running_indexing_tasks_by_node_id, last_applied_plan.indexing_tasks_per_indexer(),