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!

Reply via email to