Hi Rajeev,
In that case may be you can add a method called setGroup on your spout/bolt and
set the value to 4 in flux using configMethods and then override
getComponentConfiguration method in your spout/bolt to return a map that has
the configuration that you would add in first place using Topo
Hi Priyank,
Thanks for the reply.
I think the configMethods can be used within the spout or bolt codes.. but
i need to use the configuration for my custom scheduler like how we can do
it from java topology builder.
Can we do the same in flux ?
Regards,
Rajeev.
On Tue, 30 Jan 2018 at 03:32, Priya
I misread your first question in previous email.
Does not look like setting number of tasks is supported(or straightforward)
using flux yaml. Number of executors is supported
From: Priyank Shah
Reply-To: "user@storm.apache.org"
Date: Monday, February 5, 2018 at 10:56 AM
To: "user@storm.apache.
Hi,
Please find answers inline and check out
http://storm.apache.org/releases/2.0.0-SNAPSHOT/flux.html for more information
From: Rajeev
Reply-To: "user@storm.apache.org"
Date: Monday, February 5, 2018 at 2:15 AM
To: "user@storm.apache.org"
Subject: Number of Tasks in Flux yaml file
Hi,
1
Hi,
1) Can anyone tell me how to specify the number of tasks for a spout or
bolt in a Flux yaml file ?
2) Does parallelism in flux yaml file mean the number of executor for the
spout or bolt ?
3) Can we use custom scheduler to schedule the topology based on flux yaml ?
Regards,
Rajeev.
