Я сталкиваюсь с проблемой: необходимо Must submit topologies using the 'storm' client script so that StormSubmitter knows which jar to upload
при отправке топологии в производственный кластер с помощью IDE, а то же самое, если я выполняю в командной строке с помощью команды storm jar
, это бегать как небеса. Я видел примеры того же от githublink.
Для представления топологии я использую эти строки
conf.put(Config.NIMBUS_HOST, NIMBUS_NODE);
conf.put(Config.NIMBUS_THRIFT_PORT,6627);
conf.put(Config.STORM_ZOOKEEPER_PORT,2181);
conf.put(Config.STORM_ZOOKEEPER_SERVERS,ZOOKEEPER_ID);
conf.setNumWorkers(20);
conf.setMaxSpoutPending(5000);
StormSubmitter submitter = new StormSubmitter();
submitter.submitTopology("test", conf, builder.createTopology());
Пожалуйста, предложите мне, если это правильный подход к запуску?