Как сбалансировать топологию Storm Trident

Из этой ссылки на документацию я мог узнать что повторно сбалансировать топологию легко с помощью приведенной ниже команды

storm rebalance mytopology -n 5 -e blue-spout=3 -e yellow-bolt=10

Но как мне повторно сбалансировать топологию трезубца, поскольку в топологии трезубца мы не можем маркировать фильтры/функции (болты) именем, так как я могу увеличить/уменьшить количество параллелизма? Или есть ли способ увеличить/уменьшить количество параллелизма, используя множитель для всех компонентов в определенной топологии?


apache-storm trident
person Aride Chettali    schedule 13.07.2015    source источник

Ответы (1)


arrow_upward
2
arrow_downward

Позвольте мне ответить на мои собственные вопросы;

В случае Trident носикам и болтам автоматически присваиваются имена b-0,b-1,b-2. Это расшифровывается как Blot-1 и Bolt-2. Это имя можно определить в пользовательском интерфейсе Storm для развернутой топологии.

Теперь, используя эти имена болтов, мы можем перебалансировать развернутую топологию.

storm rebalance mytopology -n 5 -e b-0=3 -e b-1=10

ПРИМЕЧАНИЕ. Вы также можете назвать болт при создании топологии трезубца.

eg; 

 topology.newStream("spout", spout)
         .each(new Fields("sentence"), new Split(), new Fields("word"))
         .shuffle()
         .name("BOLT-NAME")
person Aride Chettali    schedule 27.07.2015