[Newbie Question] How to build DRPC based topology with multiple spouts

2016-02-09 Thread Rahul R
I have a topology which is similar to LinearDRPC topolgy mentioned in here . The major difference being, my bolts have multiple spouts. I am attaching a svg for my topology as a visual aid. Initially I had coded using localDRPC and

Re: worker cannot download topology from nimbus host

2016-02-09 Thread Abhishek Agarwal
The logs suggest a different problem altogether. Supervisor is not able to connect to nimbus host. Check that nimbus is running and reachable from other machines. Make sure the nimbus.host in storm configuration is correct for all the supervisor machines On Tue, Feb 9, 2016 at 4:19 PM, RAISUL

HBase lookup bolt - exception

2016-02-09 Thread Raja . Aravapalli
Hi, For the HBase lookup bolt of my storm topology, i am facing below exception... Request your help to identify and fix the issue ASAP. java.lang.RuntimeException: java.lang.IllegalArgumentException: Row length is 0 at

Re: The best way to unit test a Bolt with dependency?

2016-02-09 Thread Spico Florin
Hello! Set RabbitMQUtils as transient field in order to get rid of serialization error. See if you can mock (Mockito using) your RabbitMQ utils and inject it via setMQ. Hope that these help. Regards, Florin On Tue, Jan 19, 2016 at 7:16 PM, Noppanit Charassinvichai < noppani...@gmail.com>

Re: worker cannot download topology from nimbus host

2016-02-09 Thread RAISUL BHUIYAN
Hello Abhishek, Thank you very much for your reply. It works fine when all the workers are in windows computer. But if I add Ubuntu then it starts to crashes. I checked the Nimbus log it does not shows any error report. I have added the ui_image and nimbus.log file. Hope to hear from

Re: HdfsSpout

2016-02-09 Thread Artem Ervits
does this help? https://github.com/apache/storm/tree/master/external/storm-hdfs On Tue, Feb 9, 2016 at 1:44 AM, K Zharas wrote: > That is all about "HdfsBolt", not "HdfsSpout" > > On Tue, Feb 9, 2016 at 7:09 AM, Artem Ervits > wrote: > >> Here is some

Re: HdfsSpout

2016-02-09 Thread K Zharas
Yes, I have faced above mentioned problems after following that. Please, reread my question. On Wed, Feb 10, 2016 at 1:37 AM, Artem Ervits wrote: > does this help? > https://github.com/apache/storm/tree/master/external/storm-hdfs > > On Tue, Feb 9, 2016 at 1:44 AM, K