Submitting a topology to Storm

apache-storm
Mahi Singh picture Mahi Singh · Sep 19, 2013 · Viewed 13k times · Source

I have configured Storm on my machine. Zookeeper, Nimbus and Supervisor are running properly. Now I want to submit a topology to this storm. I am trying to use storm jar. but I am not able to submit it. Can anybody please give an example for this. It will be very helpful. Thanks in advance:)

Answer

Munim picture Munim · Sep 19, 2013

The answer is in the official documentation, and it is clear enough. Run storm jar path/to/allmycode.jar org.me.MyTopology arg1 arg2 arg3 (replace with your project name and arguments if any). Make sure you are using StormSubmitter object instead of LocalCluster.

Related questions

java.lang.NoSuchFieldError: INSTANCE

When trying to submit my topology through StormSubmitter, I am getting - Caused by: java.lang.NoSuchFieldError: INSTANCE at org.apache.http.impl.io.DefaultHttpRequestWriterFactory.<init>(DefaultHttpRequestWriterFactory.java:52) I am using Spring. I am not initializing HttpClient in …

Read More
Apache Kafka vs Apache Storm

Apache Kafka: Distributed messaging system Apache Storm: Real Time Message Processing How we can use both technologies in a real-time data pipeline for processing event data? In terms of real time data pipeline both seems to me do the job …

Read More
What is/are the main difference(s) between Flink and Storm?

Flink has been compared to Spark, which, as I see it, is the wrong comparison because it compares a windowed event processing system against micro-batching; Similarly, it does not make that much sense to me to compare Flink to Samza. …

Read More