Re: Storm submit problem

Have u started nimbus , supervisor and zookeeper ? On Fri, Aug 8, 2014 at 11:07 AM, ​Chandrahas Gurram chandraha...@peel.com wrote: Hi, I am trying to submit my jar to nimbus using the command storm jar pathtofile mainclassname arguments. it is throwing connection refused error. can anyone

Re: Storm submit problem

yes they are up. ThankYou, G V Chandrahas Raj On Fri, Aug 8, 2014 at 11:28 AM, padma priya chitturi padmapriy...@gmail.com wrote: Have u started nimbus , supervisor and zookeeper ? On Fri, Aug 8, 2014 at 11:07 AM, ​Chandrahas Gurram chandraha...@peel.com wrote: Hi, I am trying to

how trident managing if max transaction id reached.

Hi all, how trident managing if max transaction id reached? is it recycle the transaction ids. regards Tarkeshwar

Re: Cannot create run the topology due to java.io.NotSerializableException: java.util.concurrent.CountDownLatch

Hello, Nathan! Thank you very much for your support. After instantiating my unserializable class in the open method of the spout , everything went well. Best regards, Florin On Thu, Aug 7, 2014 at 5:45 PM, Nathan Leung ncle...@gmail.com wrote: Most things your spout or bolt uses,

Error in Supervisor : Error when processing event java.lang.RuntimeException: java.io.EOFException

Hi, I am getting following error in the supervisor logs for storm- 0.9.0.1 : 2014-08-08 04:32:42 b.s.d.supervisor [INFO] Starting supervisor with id 15eb83b6-a5ab-4f13-b783-06a8dbe0b2a2 at host localhost.localdomain 2014-08-08 04:32:43 b.s.event [ERROR] Error when processing event

RE: Storm submit problem

Can you show us the full stacktrace of the error you are getting. From: ​Chandrahas Gurram [mailto:chandraha...@peel.com] Sent: 08 August 2014 07:17 To: user@storm.incubator.apache.org Subject: Re: Storm submit problem yes they are up. ThankYou, G V Chandrahas Raj On Fri, Aug 8, 2014 at 11:28

Re: Storm submit problem

1262 [main] INFO backtype.storm.StormSubmitter - Jar not uploaded to master yet. Submitting jar... 1772 [main] INFO backtype.storm.StormSubmitter - Uploading topology jar my jar path to assigned location: /mnt/storm/nimbus/inbox/stormjar-097f2024-b581-4413-b6c8-5b4431f3309e.jar Exception in

Re: Can't print the message by KafkaSpout

Hi Alec I've run into this problem as well, when Storm brings up a worker it adds a number of jars to the classpath, including Zookeeper, which Storm itself depends on. Take a look in your supervisor log, you should see lines beginning with: b.s.d.supervisor [INFO] Launching worker with command:

RE: KafkaSpout repeatedly sending the same message over and over again

The Kafka spout has guaranteed messaging processing turned on . Your bolt mist ack the incoming tuple. If you extend BaseBasicBolt , it has acknowledge builtin . Hope this solves your problem. -Original Message- From: Kushan Maskey Sent: 08-08-2014 AM 02:11 To:

Re: How do I implement this topology in Storm?

It's an option but if I understand correctly the field grouping will make sure each word goes to the same bolt every time, I'm guessing this requires some sort of central authority to coordinate. How does that happen? On Fri, Aug 8, 2014 at 8:27 PM, Nathan Leung ncle...@gmail.com wrote: Why

Re: How do I implement this topology in Storm?

The logic for fields grouping is stateless. It does a hash mod on the field values. Essentially: selectedTask = fields.hashCode() % numTasks - Taylor On Aug 8, 2014, at 1:39 PM, Jonathan Yom-Tov jon.yom...@gmail.com wrote: It's an option but if I understand correctly the field grouping will

Re: How do I implement this topology in Storm?

OK, thanks. And is there another option if I don't want to go down the fields grouping path? On Fri, Aug 8, 2014 at 8:52 PM, P. Taylor Goetz ptgo...@gmail.com wrote: The logic for fields grouping is stateless. It does a hash mod on the field values. Essentially: selectedTask =