Re: Betty connection fail

I found another situation to cause netty reconnect: I remove many files, at the same time, I wc some files, and the files are very large(about 600G), so the IO is very very high(about 100M/s). No resource for netty to handle connection request, it leads reconnect. So, I guess if load of the

How to change already uploaded python Bolt code

Hi Is there possible to change already submitted python Bolt's code that way I do not need to submit new topology again. I tried just change code in nodes and killed python process in topology nodes and it worked. But this is hack. -- Margus (margusja) Roo http://margus.roo.ee skype:

Emitting Custom Object as Tuple from spout

Hi , I am new to apache Storm . To understand it I was looking at storm examples provided in the storm tutorial ( https://github.com/apache/storm/tree/master/examples/storm-starter) . In all the examples , we are emitting prmitive types (String,int etc) as Tuples . In my use case I am having

RE: Emitting Custom Object as Tuple from spout

Hi, For your bolt: YourBean yb = new YourBean(); yb.setFoo(“foo”); outputCollector.emit(anchor, new Values(yb)); For your spout: https://github.com/nathanmarz/storm-starter/blob/master/src/jvm/storm/starter/spout/RandomSentenceSpout.java You might want to register a custom serializer though –

Re: Emitting Custom Object as Tuple from spout

You emit like this: collector.emit(new Values(yourBeanInstanceHere)); You just need to wrap it in a Values object. Regards, Javier. On Sep 16, 2015 9:37 AM, "Ankur Garg" wrote: > Hi , > > I am new to apache Storm . To understand it I was looking at storm > examples