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)
        .allGrouping(BOLT_A_ID)
        .fieldsGrouping(BOLT_B_ID, new Fields("some-key");

Bolts A and B produce tuples at the same time... i.e. their tuples will
arrive bolt C(same instance of this bolt) almost at the same time. Will
storm core postpone execution of the "second" tuple until "first" will be
processed? Or it will fire "execute" exactly when it will receive tuple(i.e
in parallel to current execution)?

PS Storm version 1.1.0

Reply via email to