Do not add it to the yaml file, but set the parameter in the Config object you hand over when submitting the topology. (Config values overwrite yaml values)
Config c = new Config();
c.put("topology.worker.childopts", "-Xmx4g");
StormSubmitter.submitTopology("t-name", c, builder.createTopology());
-Matthias
On 04/16/2016 03:22 PM, Benjamin Cuthbert wrote:
> But does that not set it for all workers? What If I want to the specific?
>
> Regards
>> On 16 Apr 2016, at 14:19, Matthias J. Sax <[email protected]> wrote:
>>
>> topology.worker.childopts
>>
>> On 04/16/2016 02:38 PM, Benjamin Cuthbert wrote:
>>> All,
>>>
>>> How do you set the individual worker Xmx settings for different topologies.
>>>
>>
>
signature.asc
Description: OpenPGP digital signature
