You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Weide Zhang <we...@gmail.com> on 2014/05/11 18:29:18 UTC

trident parallelization and failover

Hi,

If i have specify parallelHint for TridentTransactionalKafkaSpout as more
than 1, internally, what's the class of the instance of trident bolt is
created more than 1 times ? Is it tridentspoutexecutor or
tridentspoutcoordinator or both ?  Can they run on different worker node ?

Also, it seems either masterbatchcoordinator and tridentspoutcoordinator
manages the whole topology status.  what if they fail and nimbus restarted
worker node? will we lose information and will exact once semantic still be
achieved ?

Thanks,

Weide