Two simultaneous tuples from 2 incoming stream process order

2019-06-05 Thread bogun . dmitriy
Hi. It is possible the "execute" method of the bolt to be called in "parallel"? For example we have 3 bolts A, B and C: topology.setBolt(BOLT_A_ID, new BoltA(), scaleFactor); topology.setBolt(BOLT_B_ID, new BoltB(), scaleFactor); topology.setBolt(BOLT_C_ID, new BoltC(), scaleFactor) .allG

Re: Two simultaneous tuples from 2 incoming stream process order

2019-06-05 Thread Stig Rohde Døssing
The "execute" method will never be called concurrently on the same bolt instance. In your topology, you will have some number of bolt C copies running (the task count for bolt C). Each copy will only receive one tuple in "execute" at a time. Any other tuples received while "execute" is running will