Описание тега apache-storm-configs
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
1
ответ
Об эффекте параллелизма в StormCrawler
В настоящее время я работаю над проектом на основе Storm Crawler. У нас есть фиксированная и ограниченная пропускная способность для загрузки страницы из Интернета. У нас есть 8 рабочих с большим значением подсказки параллелизма для разных Bolt в то…
16 окт '20 в 10:06
0
ответов
Различные конфигурации топологии для режимов разработки и производства в Apache Storm
В настоящее время в нашей команде мы работаем над проектом на основе Apache Storm. У нас есть две разные изолированные среды для разработки и производства. Каждая среда имеет свои собственные значения для конфигураций топологии. Есть ли в Storm каки…
08 ноя '20 в 08:49
0
ответов
Storm Bolt принимает кортежи, но Spout выдает их с большой задержкой
У меня довольно простая структура топологии. Носик -> Болт и все. Но время от времени я получаю такую картину: пользовательский интерфейс Storm . И понятия не имею, почему это может произойти. Bolt обрабатывает все кортежи, но spout не все. У м…
27 окт '21 в 17:58
0
ответов
Время ожидания кортежа Apache Storm истекло через 10 минут, но параметр topology.message.timeout.secs настроен как 5 минут
У нас есть топология с topology.message.timeout.secs = 300 секунд. Недавно мы столкнулись с проблемой, когда первый болт после носика достигал емкости ~2. Болт начал обрабатывать кортежи очень медленно (он начал обрабатывать кортежи через 5 минут по…
03 ноя '21 в 10:17
0
ответов
Отказоустойчивость Apache Storm Nimbus меняется при настройке двойного нимба. (2.2.0)
Согласно документации Storm , сбои демона не должны влиять на рабочие процессы в супервизорах. Это работает для моей топологии (в версии 2.2.0), когда единственный нимб убит. Супервайзеры продолжают обработку. (Однако только что запущенный контейнер…
21 дек '21 в 18:10
0
ответов
Отметьте кортеж в болте python в Apache Storm
Я хочу использовать кортеж тиков в болте оболочки Python в Apache Storm. Есть ли способ сделать это? Основные части моей топологии были написаны на java, и у нас есть один болт Python.
10 мар '21 в 12:10
0
ответов
Как установить ограничение рабочей памяти Apache Storm (2.2.1)?
Я обновил Apache Storm с 1.1.1 до 2.2.1, использовал ту же конфигурацию и топологию. Но 2.2.1 не может запустить рабочий процесс. Вот моя конфигурация: worker.childopts: "-Xms1g -Xmx3g -Xmn378m -XX:SurvivorRatio=2 -XX:+UseConcMarkSweepGC -XX:+UseCMS…
16 фев '22 в 06:05
1
ответ
Топология не выполняется в локальном кластере
Я пытался изучить шторм apache и настроить шторм на моей Ubuntu, установленной в vmware. Storm версии 2.4.0 и в настоящее время работает на локальном хосте. Когда я отправляю топологию. Топология успешно отправлена и распределена в соответствии с …
06 янв '23 в 21:41
0
ответов
Заказ и комплектация наборов в шторм с носиком кафки
Когда у нас есть топология, которая берет записи чтения из kafka, сохраняется ли входящий порядок при обработке событий? Допустим, топология A Kakfa spout -> B bolt -> C bolt -> D bolt -> H bolt | ^ | | -> E bolt -> F bolt -> G …
09 июн '22 в 04:07
0
ответов
Можем ли мы настроить единый интерфейс Storm для всех Nimbus?
мой вопрос: можем ли мы использовать только один интерфейс шторма для нескольких нимбов? потому что, если nimbus не работает на машине, пользовательский интерфейс также получает ошибку в браузере. даже не лидер нимб меняется как лидер (который работ…
13 июн '22 в 05:50
0
ответов
Storm 2.4.0 — проблема с размером рабочей кучи
Хотя мы указали следующие параметры в Storm.yaml, он вычисляет выделенный общий объем памяти путем умножения количества исполнителей в топологии на onheap(128 МБ). `topology.component.resources.onheap.memory.mb: 128.0 topology.component.resources.of…
08 авг '23 в 15:09
1
ответ
Окно шторма Apache, создающее дубликаты кортежей в случае истечения времени ожидания сообщения
Я использовал BaseWindowBolt из Apache Storm. Однако в случае истечения времени ожидания сообщения я вижу дубликаты пакетов. Например, ниже приведена моя тестовая конфигурация. Я использую носик Kafka для чтения данных из темы. У меня есть болт с ра…
03 июн '23 в 11:43
0
ответов
Окно визуализации пользовательского интерфейса Apache Storm не работает
Я получаю эту ошибку при попытке открыть окно визуализации в пользовательском интерфейсе Apache Storm и показывает пустую страницу. «org.apache.storm.thrift.transport.TTransportException: размер кадра (35307746) превышает максимальную длину (1048576…
24 авг '23 в 08:33
0
ответов
Apache Storm 2.4.0 работает медленнее по сравнению с Apache Storm 0.9.6
Я перехожу на ApacheStorm 2.4.0 с ApacheStorm 0.9.6. Но производительность ApacheStorm 2.4.0 ниже. Я читал, что стратегия ожидания играет роль в производительности. Выход из приложения в ApacheStorm 0.9.6 имеет следующую конфигурацию стратегии ожида…
23 авг '23 в 14:48
0
ответов
Отчет о показателях шторма Apache не работает должным образом
Я использую версию Apache Storm 2.4.0, и мы хотим, чтобы все наши метрики были доступны. Итак, мы создали сервис, который в настоящее время принимает все метрики и предоставляет метрики в конечной точке /metrics. Storm использует метрики Drop-Wizard…
13 апр '23 в 07:27