apache-storm

1зной

1ответ

Совместное использование BlockingQueue в штормовом носике

Я программирую большое приложение данных, в котором два потока работают одновременно. Thread A получает данные из сети и помещает их как JSONOBJECT в BlockingQueue. Ветвь B, штормовой носик, затем чит

0зной

1ответ

Измерительная латентность штормовых болтов

Я пытаюсь измерить латентность каждого болта в топологии. Количество задержек, предоставляемое Storm, недостаточно, так как мы хотим рассчитать процентили. В моей текущей настройке я измеряю задержку

-1зной

1ответ

Как получить доступ к файлам из каталога в апаче шторма

Как получить доступ к файлам в директории с помощью болта апача штормовой топологии в классе топологии им проходящего объект класса AnnotationTest Config conf = new Config(); conf.put("gateObject", n

0зной

2ответ

конфликты версии sl4j в градиенте со Storm 1.0.1 и elasticsearch 5.2

Мы столкнулись с конфликтами версии sl4j в градиенте со Storm 1.0.1 и elasticsearch 5.2. Мы обнаружили, что ElasticSearch нуждается в мосту log4j-to-slf4j, чтобы мы могли использовать нужные регистрат

0зной

1ответ

Apache Storm & Vagrant. org.apache.storm.utils.NimbusLeaderNotFoundException

Я новичок в Apache Storm и Vagrant, и я хочу развернуть мою топологию на виртуальном кластере, построенном с использованием Vagrant. Тем не менее, я постоянно получаю org.apache.storm.utils.NimbusLead

1зной

1ответ

OpenCV - Apache Storm появление 'UnsatisfiedLinkError'

Я использую (Apache Storm1.0.0 + OpenCV3.2.0) для распространения видео обработки. Я уже представил топологию кластеру, но рабочие, похоже, не работают. Поэтому я проверил журналы узла3 (рабочий), кот

1зной

1ответ

Kafka spout интеграция

Я использую kafka 0.10.1.1 и storm 1.0.2. В документации по бури для интеграции kafka я вижу, что смещения все еще поддерживаются с использованием zookeeper, поскольку мы инициализируем kafka spout с