Я получаю следующую ошибку при развертывании топологии штормового кластера на супервизоре. Я не могу понять точную причину, поскольку супервизор может найти топологию, но не может загрузить код и выполнить. 2018-01-02 12:23:42.409...

Как я могу найти слово, которое имеет максимальное количество слов в топологии подсчета слов, используя топологию Trident? Вот ссылка на топологию подсчета слов Trident....

Я попытался построить кластер Heron, используя Apache Mesos, Apache Aurora, ZooKeeper и HDFS. Однако, когда я отправляю WordCountTopology после ее завершения, команда выводит следующее: Остановка «Создание задания WordCountTopology»....

Штормовая версия - 1.0.6. У меня есть собственный сериализатор, зарегистрированный для одного из моих классов. Как и ожидалось, вызывается метод записи, который успешно выполняется. Однако метод read моего пользовательского сериализатора вообще...

Наша топология Apache Storm прослушивает сообщения от Kafka с помощью KafkaSpout и после выполнения большого количества сопоставлений/уменьшения/обогащения/агрегации и т. д. и т. д. и т. д., наконец, вставляет данные в Cassandra. Есть еще один вход...

Наша топология Apache Storm прослушивает сообщения от Kafka с помощью KafkaSpout и после выполнения большого количества сопоставлений/уменьшения/обогащения/агрегации и т. д. и т. д. и т. д., наконец, вставляет данные в Cassandra. Есть еще один вход...

Я прочитал json от Kafka, FieldExtractionBolt читает, что json извлекает данные в значения кортежа и передает их CassandraWriterBolt, который, в свою очередь, записывает запись в Cassandra, записывая все эти значения кортежа в отдельные столбцы....

Я новичок в Apache-Storm. Я пытаюсь создать локальный штормовой кластер. Я установил zookeeper, используя следующую ссылку , и когда я запускаю zookeeper работает нормально, но когда я запускаю nimbus с помощью команды start nimbus , я вижу...