Ребаланс в Trident

Мне интересно, как лучше всего перебалансировать топологию Trident? Топология Storm Trident, кажется, устанавливает количество задач в соответствии с намеками на параллелизм потока. Когда я запускаю команду перебалансировки, я не могу увеличить количество исполнителей, поскольку исполнителей должно быть ‹= # задач. Я использую Шторм 9.0.1. Любые выводы будут оценены.


person ybensimhon    schedule 21.02.2014    source источник
comment
Вы пытались увеличить параллелизм? Кроме того, это зависит от количества доступных рабочих, если все они исчерпаны, предположим, вам нужно больше оборудования (или украсть из другой топологии).   -  person noMAD    schedule 22.02.2014
comment
да, запуск перебалансировки с -e не увеличивает количество исполнителей (кстати, уменьшение работает). Я предполагаю, что это из-за границы задач. Не думайте, что это связано с количеством рабочих, я пытаюсь увеличить количество исполнителей.   -  person ybensimhon    schedule 22.02.2014
comment
Я рассказал вам о воркерах, потому что вы пытались запустить команду rebalance, которая изменила бы только количество воркеров. Если вы хотите изменить исполнителей (потоки, которые запускает каждый рабочий), вам нужно попробовать изменить параллелизм. Также попробуйте другой тип группировки (в зависимости от ваших потребностей)   -  person noMAD    schedule 22.02.2014


Ответы (1)


Количество задач всегда должно быть больше или равно количеству исполнителей. Поэтому используйте большие значения parallelism_hint, и тогда вы сможете повторно сбалансировать количество исполнителей для соответствия.

person user2601228    schedule 25.02.2014