apache-storm

1зной

1ответ

Разверните болты/носик конкретному супервизору

Мы запускаем приложение шторма, используя один тип, например, в AWS, и одну топологию для запуска нашей системы. Это вызывает некоторые проблемы с ограничением ресурсов. То, как мы хотим это решить, с

0зной

1ответ

Как обрабатывать дублирование событий, вызванных повтором Шторма в случае сбоя() от одного из болтов

у меня есть топология с носиком S и 3 болта - A, B, C. болт читает Spout S. Bolt A затем разбивает данные на болты B и C (на основе некоторого фильтра). Болты B и C имеют свои приемники данных. Если я

0зной

2ответ

Шторм не может найти путь класса jar в моей собственной баночке

При попытке научиться использовать шторм. Я решил скомпилировать свой собственный экземпляр известной топологии WordCount, чтобы посмотреть, как это делается. Код на 100% идентичен этому примеру. (htt

0зной

1ответ

Что происходит, когда болт не может получить кортеж, который он потребляет из определенного потока носика?

Скажем, у меня есть носик, который пропускает сообщения в теме в два потока (stream1 & stream2), и два болта потребляют сообщения из этих потоков (bolt1 -> stream1, bolt2 -> stream2). Теперь, если бол

0зной

1ответ

Редактирование процесса болтов во время выполнения в Apache Storm

Мой проект передает данные объекта объекту через шторм графическому приложению. Появление этих объектов зависит от переменных, заданных болтом в топологии шторма. Вопрос в том, можно ли обновить проце