FAQ Database Discussion Community


storm supervisor exits when processing event

java,storm,apache-storm
when i start the supervisor by issuing bin/storm supervisor it exits. The logs are with 2015-06-12T02:28:27.811-0700 b.s.event [ERROR] Error when processing event java.lang.NoSuchMethodError: org.apache.commons.io.FileUtils.moveDirectory(Ljava/io/File;Ljava/io/File;)V at backtype.storm.daemon.supervisor$fn__7480.invoke(supervisor.clj:489) ~[storm-core-0.9.5.jar:0.9.5] at clojure.lang.MultiFn.invoke(MultiFn.java:241) ~[clojure-1.5.1.jar:na] at...

Apace Storm Sync method

python,apache,apache-storm
I am using Storm 0.9.3, using Python. I referred this link https://storm.apache.org/documentation/Multilang-protocol.html. Can anyone explain, what the sync() is doing method? what is the frequency of heartbeat tuple? ...

Getting backtype.storm.generated.InvalidTopologyException: null .If I comment call to setBolt it runs

apache-storm
If comment builder.setBolt then it runs correctly.Please tell where I am getting wrong TopologyBuilder builder = new TopologyBuilder(); builder.setSpout("words", new TestWordSpout(), 3); //Calling setBolt builder.setBolt("exc", new ExclaimBolt(),3) .allGrouping("words"); Config conf = new Config(); conf.setDebug(false); //conf.setNumWorkers(2); LocalCluster cluster = new LocalCluster(); cluster.submitTopology("test", conf, builder.createTopology()); ...

How to make my topology cycle run completely before starting it again?

apache-storm
I have a spout which does some processing in nextTuple() and emit values to kafka bolt. Once the kafka bolt acknowledges, spouts ack() method is called. In my case before ack() method is finished, topology calls the nextTuple() method of the spout. Is there anyway to control over topology to...

Storm UI to display topology after killed

storm,apache-storm
Is there a configuration parameter in storm so that a topology will still be displayed after it is killed ? Thank you...