Hi
“package my code” is must , because running your topology on
storm cluster needs this jar .
===========================================================================>
System.setProperty("storm.jar",
"E:/workspace/cdc-dp-data-storm-project/target/cdc-cdp.jar");
Config config=new Config();
config.setDebug(false);
config.put(Config.NIMBUS_HOST,"cq01-crm-lin2rd52.vm");
config.put(Config.NIMBUS_THRIFT_PORT,8889);
config.setNumWorkers(2);
StormSubmitter.submitTopology("cdp-reader-online", config,
builder.createTopology());
Every time , I package my code into one jar location
"E:/workspace/cdc-dp-data-storm-project/target/cdc-cdp.jar" again , then
run this codes to submit the topology
Thx
发件人: ch huang [mailto:[email protected]]
发送时间: 2014年1月13日 11:02
收件人: [email protected]
主题: Re: how can i connect remote storm cluster and submit topology?
now ,problem is i the storm cluster is ready , i get a linux box for test
,change /root/.storm/storm.yaml to point to the cluster nimbus , and submit
the ExclamationTopology through the following command
# storm-0.9.0-wip21/bin/storm jar
storm-starter-master/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependenci
es.jar storm.starter.ExclamationTopology exclamation-topology
it's work fine ,but i do storm topology write on a windowsXP OS box using
eclipse as IDE,i do not know how to get my code runing and submit the
topology to my remote cluster,i do not want to package my code ,and upload
it to my linux box ,then run it
On Mon, Jan 13, 2014 at 10:32 AM, Nathan Leung <[email protected]> wrote:
Assuming everything else is setup, configure your storm.yaml and then just
run the "storm jar" command. Assuming it's not, these two links are good
references:
https://github.com/nathanmarz/storm/wiki/Setting-up-a-Storm-cluster
http://www.michael-noll.com/tutorials/running-multi-node-storm-cluster/
On Sun, Jan 12, 2014 at 9:12 PM, ch huang <[email protected]> wrote:
hi,maillist:
i create a new storm project in eclipse and now question is how can
i connect to remote storm cluster ,submit the topology?
