apache-storm

3зной

4ответ

я настроил свою машину зоопарк, Нимб, супервизор работает должным образом, и моя топология работает в LocalCluster LocalCluster cluster = new LocalCluster(); cluster.submitTopology("SendPost", conf,

1зной

2ответ

Штормовые работники не начинаются

Хозяин и руководитель Nimbus работают правильно. Когда я отправляю топологию wordcount на хост Nimbus, он успешно загружается. После загрузки топологии супервизора дает ошибку kill: No such process

1зной

2ответ

Нет такого файла или каталога на болтах

Иногда я вижу следующее исключение: java.io.IOException: No such file or directory at java.io.UnixFileSystem.createFileExclusively(Native Method) ~[na:1.7.0_11] at java.io.File.createNewFi

2зной

2ответ

Должны ли штормовые носики испускать выход, используя поток, вызывающий Spout.nextTuple?

ISpout.nextTuple() javadoc указывает, что nextTuple(), ack(...) и fail(...) вызывают в той же теме. Однако фактический коллектор, на который вызывается emit(...), предоставляется в качестве параметра

2зной

1ответ

Как транспортировать и индексировать данные Кассандры об упругом поиске?

Я начинаю приложение nodejs, где я хочу индексировать данные Cassandra по Elastic Search, но что было бы лучшим способом сделать это? Я взглянул на Storm, чтобы выполнить именно это, но, похоже, решен