You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by pavidhanaj <pa...@zoho.com> on 2019/05/29 14:25:33 UTC

Bolts Not getting Tuple

Hi, 



I need to use the bolt which has to consume the data emitted from one spout and two different bolts, (i.e) tuples emitted from spout_1, bolt_1 and bolt_2 will go to bolt_3. And I need to apply fields grouping for all the tuples received in bolt_3, 

I declared the bolt as following.

      builder.setBolt("bolt_3", new LiveDataBolt(), 12) 

            .fieldsGrouping("spout_1", new Fields("id"))

            .fieldsGrouping("bolt_1", new Fields("id"))

            .fieldsGrouping("bolt_2", new Fields("id"));


but the bolt doesn't consume any data. Do i need to declare them in any other way? 







Thanks 

Pavithra







Sent using https://www.zoho.com/mail/

Re: Bolts Not getting Tuple

Posted by Stig Rohde Døssing <st...@gmail.com>.

Hi Pavithra,

The wiring looks fine to me. Most likely the issue is in the bolt code.
Could you post the spout_1/bolt_1/bolt_2 code as well (at least the bit
related to emitting)?

Den ons. 29. maj 2019 kl. 21.11 skrev pavidhanaj <pa...@zoho.com>:

>
> Hi,
>
> I need to use the bolt which has to consume the data emitted from one
> spout and two different bolts, (i.e) tuples emitted from spout_1, bolt_1
> and bolt_2 will go to bolt_3. And I need to apply fields grouping for all
> the tuples received in bolt_3,
> I declared the bolt as following.
>
>       builder.setBolt("bolt_3", *new* LiveDataBolt(), 12)
>
>             .fieldsGrouping("spout_1", *new* Fields("id"))
>
>             .fieldsGrouping("bolt_1", *new* Fields("id"))
>
>             .fieldsGrouping("bolt_2", *new* Fields("id"));
>
> but the bolt doesn't consume any data. Do i need to declare them in any
> other way?
>
>
> Thanks
> Pavithra
>
>
>
> Sent using Zoho Mail <https://www.zoho.com/mail/>
>
>
>
>
>
>
>
>