Slackbot
06/01/2023, 5:24 PMSergio Ferragut
06/01/2023, 5:46 PMdruid.coordinator.period
) and checks for published/used segments and all the current retention rules
• for each segment it evaluates which retention rule to apply
• it prioritizes loading segments which have no presence within the target tier and then replicas
• it generates load/drop commands for historicals
The historicals read the load/drop commands from their load queue which has a max depth of maxSegmentsInNodeLoadingQueue. Each historical works independently to execute its load/drop commands using one or more threads based on each historical's config druid.segmentCache.numLoadingThreads
To answer your question directly, AFAIK, the coordinator does not prioritize by tier but you can control the resources used by the historicals in each tier for segment loading.Josh Sylvestre
06/01/2023, 6:03 PMJRob
06/02/2023, 2:29 AM