Como enviar uma topologia no cluster de produção de tempestade usando o IDE

Question

Apr 03, 2013, 09:20 AM

Como enviar uma topologia no cluster de produção de tempestade usando o IDE

Estou enfrentando um problemaMust submit topologies using the 'storm' client script so that StormSubmitter knows which jar to upload ao enviar uma topologia para um cluster de produção usando o IDE, enquanto a mesma coisa se eu executo na linha de comando usandostorm jar comando, está correndo como o céu. Eu vi exemplos do mesmogithublink.

Para enviar topologia, estou usando esse conjunto de linhas

    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());

Por favor me sugerir se esta é a abordagem correta para executar?