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

Popular posts from this blog

javascript - Karma not able to start PhantomJS on Windows - Error: spawn UNKNOWN -

c# - Display ASPX Popup control in RowDeleteing Event (ASPX Gridview) -

Nuget pack csproj using nuspec -