Как настроить емкость индексации Druid?

Question

По умолчанию имеется 2 слота индексации при запуске друида на автономной машине.

Если у вас есть более 2 источников данных kafka для индексации, всегда есть 2 запущенные задачи, и они находятся в состоянии отложенных задач.

Мой вопрос заключается в том, как увеличить емкость слотов для индексирования друидов, чтобы они могли параллельно выполнять больше задач?Спасибо!

Answer 1

Вы можете изменить количество задач, обновив нижеприведенное свойство в middlemanager runtime.properties.

# Number of tasks per middleManager 
druid.worker.capacity=2

Но имейте в виду, что вам также необходимо обновить распределение системных ресурсов, например.если ваша система имеет только 2 процессора, она не будет работать.