Я тестирую случай, используя Storm 1.2.2 и Kafka 2.x в качестве моего Spout. Поэтому я создал...
[ОШИБКА] Не удалось выполнить цель org.apache.maven.plugins: maven-surefire-plugin: 2.22.1: тест...
[ОШИБКА] Не удалось выполнить цель org.apache.maven.plugins: maven-checkstyle-plugin: 3.0.0:...
Я пытаюсь понять состояние топологии в случае тайм-аута обработки кортежа (не в режиме Trident)....
Я пытаюсь настроить KafkaSpout через YAML и получаю следующее сообщение об ошибке Исключение в...
Я храню этот вид дерева в монго: { "00010": { "1.1":[1,3,4], "4.0":[2...
Я использую болт R для обработки моих данных. Я хочу отправить обработанные данные из болта R в мой...
Storm имеет возможность настроить размер памяти для каждого компонента (болт / носик) с помощью...
Когда задание Storm отправляется в кластер Hadoop для записи в hdfs с использованием hdfsbolt, в...
Я создал пример топологии со Storm, используя Кафку в качестве источника. Вот проблема, решение...
в качестве заголовка. У меня есть грозовой кластер с 20 машинами, один для нимба и 19 для...
У нас проблема с параллелизмом задач внутри одной топологии. Нам не удается получить хорошую,...
Я новичок в Apache Storm. Я пытаюсь разработать систему обработки потоков в реальном времени с...
Я хочу распараллелить оконную операцию в шторме Apache или, другими словами, распределенную оконную...
Я хочу использовать шторм-стартер в intellij Я настраиваю строго как официальный сайт...
Пытаюсь получить в реальном времени данные топологий, работающих в Apache Storm, используя...
Мне нужно прочитать новые файлы, поступающие на S3 с носиком Apache Storm.Есть ли у Apache Storm...
Я использую Apache Storm Nimbus и Supervisor внутри отдельных док-контейнеров, используя...
Я разработал Java-приложение для запуска на Apache Storm.Мы будем устанавливать приложения на...
Когда я пытаюсь развернуть банку Apache Storm, разработанную мной с использованием Flux, я получаю...
Я создал топологию, которая имеет 1 носик и 2 экземпляра болта, каждый из которых работает на...
Рассмотрим следующий сценарий обнаружения мошеннических операций с кредитными картами.Транзакции...
При запуске топологии с Kafka Spout с новой версией Kafka 2.1.0 и Storm версии 1.2.2, получая...
Мой проект приложения Storm (maven) структурирован следующим образом: parent-project/ ├── pom.xml...
Я проектирую топологию Apache Storm (с использованием streamparse), построенную с одним носиком...