Running Storm - scottlove/MessageProducer GitHub Wiki

Running locally:

mvn -X exec:java -Dexec.mainClass="Topology.TopologyMain"

##Building for deployment

1. Storm-1.0-SNAPSHOT-jar-with-dependencies.jar is built with Maven. under the Maven projects, run compile and package.

running on production cluster:

1) upload file

pscp -r -P 54380 .*.jar username@serverurl:/home/username

2) running job

bin/storm jar ~/ stormapp.Topology.TopologyKafka word-count ApacheHost1 8082

3) killing job

bin/storm kill word-count

###Notes for troubleshooting: ###1) use the stormUi at: http://kafkaserver.cloudapp.net:8081/ ###2)Check log files at ~/storm/storm-0.9.0.1/logs (for example in this case issue was with zookeeper). ###3) note that nimbus and stormUI daemons are launched by upstart ###4)check the status of running jobs with stormui