Описание тега storm-topology
1
ответ
Конфигурации, связанные с памятью Apache Storm 2.1.0
Мы находимся в процессе перехода на 2.1.0 с 1.1.x. В нашей текущей настройке у нас есть следующие конфигурации памяти в storm.yaml nimbus.childopts: -Xmx2048m supervisor.childopts: -Xmx2048m worker.childopts: -Xmx16384m Я вижу много других конфигура…
19 июн '20 в 23:02
0
ответов
Когда в Apache Storm вызывается метод ack в spout?
У меня топология обработки документов на два болта. Мне нужно иметь возможность вносить изменения в структуру данных, хранящуюся в носике, после того, как документ полностью обработан / прошел через всю топологию. Прежде чем узнать больше об Apache …
01 июл '20 в 00:40
1
ответ
Обновление Apache Strom с 1.0.3 до 2.2.0, и используются не все рабочие
Я обновляюсь с Apache Storm 1.0.3 до 2.2.0 и сталкиваюсь со специфической проблемой, когда задачи топологии не выполняются на всех рабочих процессах, а выполняются только на том же рабочем узле, что и Spout. Я использую shuffleGrouping и настроил 6 …
05 ноя '20 в 03:05
0
ответов
Время ожидания кортежа Apache Storm истекло через 10 минут, но параметр topology.message.timeout.secs настроен как 5 минут
У нас есть топология с topology.message.timeout.secs = 300 секунд. Недавно мы столкнулись с проблемой, когда первый болт после носика достигал емкости ~2. Болт начал обрабатывать кортежи очень медленно (он начал обрабатывать кортежи через 5 минут по…
03 ноя '21 в 10:17
0
ответов
CassandraWriterBolt в топологии Storm не записывает в правильный кластер cassandra
Я создал топологию storm, которая считывает данные из Kafka, выполняет некоторую обработку данных и, в зависимости от некоторых условий, вставляет данные в любой из кластеров Cassandra. В обоих кластерах Cassandra имя пространства ключей, имена табл…
17 апр '22 в 06:31