Fields grouping uses a mod hash function to determine which task to send a tuple.
It sounds like there's not enough variety in the field values you are grouping such that they are all getting sent to the same task. Without seeing your code and data I can't tell for sure. -Taylor > On May 28, 2014, at 5:56 PM, Shaikh Riyaz <[email protected]> wrote: > > Hi All, > > We running Storm cluster with following servers. > > One Nimbus > Six supervisor with 2 workers each running on 6700 and 6701 ports. > > All tuples are going to only one supervisor and only to one worker (6701) > running on that supervisor. > > We have one KafkaSpout and 6 bolts processing the data. We are using > fieldgrouping to pass tuple from one bolt to another. Each tuple is saving > some data to HBase. > > One of the executor has emitted 609180 tuples and remaining executor has > emitted 200 tuples as whole. > > we have configured our spout and tuples with parallelism hint 5. > > Please let me know what might wrong with the configuration. > > Thanks in advance. > > > -- > Regards, > > Riyaz >
