Как отправить топологию в кластер шторм-производства с помощью IDE

Я столкнулся с проблемой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());

Пожалуйста, предложите мне, если это правильный подход к запуску?

Ответы на вопрос(4)

Ваш ответ на вопрос