File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
quickwit/quickwit-control-plane/src/indexing_scheduler/scheduling Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -411,17 +411,14 @@ fn place_unassigned_shards_single_source(
411
411
for PlacementCandidate {
412
412
indexer_ord,
413
413
available_capacity,
414
+ current_num_shards,
414
415
..
415
416
} in sorted_candidates
416
417
{
417
- let current_num_shards_for_indexer_and_source = * solution. indexer_assignments [ * indexer_ord]
418
- . num_shards_per_source
419
- . get ( & source. source_ord )
420
- . unwrap_or ( & 0 ) ;
421
418
let num_placable_shards_for_available_capacity =
422
419
available_capacity. cpu_millis ( ) / source. load_per_shard ;
423
- let num_placable_shards_for_limit = limit_num_shards_per_indexer_per_source
424
- . saturating_sub ( current_num_shards_for_indexer_and_source ) ;
420
+ let num_placable_shards_for_limit =
421
+ limit_num_shards_per_indexer_per_source . saturating_sub ( * current_num_shards ) ;
425
422
let num_shards_to_place = num_shards
426
423
. min ( num_placable_shards_for_available_capacity)
427
424
. min ( num_placable_shards_for_limit) ;
You can’t perform that action at this time.
0 commit comments