HI ,
i want to perform reduced my key operation example in storm, everything is
f9.here when i think my storm application want to execute fast , i increased
parallelism_hint,b4 increasing my bolt looks like below
builder.setBolt("bolt1",new DataBolt()).fieldGrouping("spout1",neew
Field("mobileno")); after increased...builder.setBolt("bolt1",new
DataBolt(),2).fieldGrouping("spout1",neew Field("mobileno"));
here how many number of executors am increasing the data comes into bolt was
duplicate , i mean when i use 2 as above , the tuple emitted by spout is comes
into bolt two times .......
please help me...........
Thanks!Regard'sprasad.ch!*
