Skip to content

Commit d5f1983

Browse files
Apply suggestion from @phillipleblanc
1 parent 6f2eeff commit d5f1983

1 file changed

Lines changed: 0 additions & 9 deletions

File tree

ballista/scheduler/src/scheduler_server/query_stage_scheduler.rs

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -329,15 +329,6 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan>
329329
self.metrics_collector
330330
.set_pending_jobs_queue_size(pending_jobs as u64);
331331

332-
// NOTE: We intentionally do NOT call total_pending_tasks() here.
333-
// That method iterates over all active jobs and acquires read locks on each
334-
// execution graph, which causes lock contention with concurrent poll_work
335-
// calls that acquire write locks during task binding. This was causing
336-
// deadlocks and executor timeouts under load.
337-
//
338-
// The pending_jobs metric above provides sufficient visibility into queue depth.
339-
// If detailed pending task counts are needed, they should be collected
340-
// periodically in a background task, not on every event.
341332

342333
Ok(())
343334
}

0 commit comments

Comments
 (0)