Hi all,
I've been using Flux to configure my topologies, but have noticed that it
doesn't let you specify the number of tasks against executors- only a
parallelism hint.
When previously configuring topologies using code, you could set the number
of executors, and then specify the number of tasks per executor, eg:
topologyBuilder.setBolt("green-bolt", new GreenBolt(), 2) .setNumTasks(4) .
shuffleGrouping("blue-spout");
(as per http://www.michael-noll.com/blog/2012/10/16/
understanding-the-parallelism-of-a-storm-topology/)
In the above example, the GreenBolt is given 2 executors, which each have 2
tasks (4 tasks total).
If you just set parallelism, you get 1 task per executor as standard.
How can I configure something like the above example using Flux?
Thanks for any help anyone can offer!