distributed system - Creating threads in Storm Bolt -
i want fire multiple web requests in parallel , aggregate data in storm topology? of following way preferred
1) create multiple threads within bolt
2) create multiple bolts , create merging bolt aggregate data.
i create multiple threads within bolt because merging data in bolt not simple process. see there concerns around found on internet https://mail-archives.apache.org/mod_mbox/storm-user/201311.mbox/%3ccaaylz+puz44gnsnnj9o5hjtr2rzlw=ckm=fgvcfwbnw613r1qq@mail.gmail.com%3e didn't clear reason why not create multiple threads. pointers help.
on side note mean should not use java8's capabilities of parallel streams mentioned in https://docs.oracle.com/javase/tutorial/collections/streams/parallelism.html?
increase number of tasks
bolt, spawning multiple instances of same. , increase number of executors (threads)
handle them evenly.
make sure #executors <= #tasks
. storm rest you.
Comments
Post a Comment