debug info

quickwit-oss · Dec 19, 2023 · 47f6a7a · 47f6a7a
1 parent 2bf0581
commit 47f6a7a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/quickwit/quickwit-control-plane/src/control_plane.rs b/quickwit/quickwit-control-plane/src/control_plane.rs
@@ -225,6 +225,7 @@ impl Handler<ControlPlanLoop> for ControlPlane {
         _message: ControlPlanLoop,
         ctx: &ActorContext<Self>,
     ) -> 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
@@ -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(),