Apache Storm Supervisor не запускает Bolt

Я создал штормовой кластер на инстансах Amazon EC2. Я тестировал свой код в локальной среде (псевдораспределенной среде), и он работал нормально. Но код не работает, когда я запускаю код в распределенной среде. Есть ли какие-то технические проблемы, которые я упустил при настройке кластера?

Я могу заявить, что супервизорные узлы не запускают болты, так как я проверил загрузку ЦП всех супервизорных узлов, и ни один из них не превышал 1%, но мастер (нимб) работал. на 100% каждый раз, пока не завершится выполнение кода.

Я также проверил процессы Java, работающие в узлах супервизора, и "jps" не показывает мою топологию.

Примечание. Кластер показывает 2 супервайзера в пользовательском интерфейсе, работающем над нимбом. Это показывает, что кластер настроен в распределенной среде.


java amazon-ec2 real-time-data apache-storm
person anuj pradhan    schedule 23.02.2015    source источник
comment
что говорит журнал .. может быть полезно, если предоставить их здесь   -  person user2720864    schedule 23.02.2015
comment
Я решил свою проблему и добавил свое решение здесь.   -  person anuj pradhan    schedule 25.02.2015
comment
Вы должны добавить свое решение в качестве ответа и принять свой собственный ответ;)   -  person Matthias J. Sax    schedule 19.10.2015
comment
@MatthiasJ.Sax Спасибо за предложение. :)   -  person anuj pradhan    schedule 20.10.2015

Ответы (1)


arrow_upward
1
arrow_downward

Решение моей проблемы:

Раньше я работал с использованием LocalCluster вместо StormSubmitter

Использовать это:

StormSubmitter.submitTopologyWithProgressBar(args[0], conf, builder.createTopology());

вместо:

LocalCluster cluster = new LocalCluster();
cluster.submitTopology("test", conf, builder.createTopology());
Utils.sleep(10000);
cluster.killTopology("test");
cluster.shutdown();
person anuj pradhan    schedule 20.10.2015