Thanks Rui, but my idea is to change it on a per topology basis. The
storm.yaml would mean changing it globally.
However, after quite some more testing I have figured that using
conf.put(Config.TOPOLOGY_WORKER_CHILDOPTS, "-XX:+UseG1GC");
does the trick :)
Am Mi., 18. Nov. 2020 um 18:42 Uhr schrieb Rui Abreu <rui.ab...@gmail.com>:
> Hello Jonas,
>
> It should be using the *worker.childopts *defined
> in storm/conf/storm.yaml.
>
> On Wed, 18 Nov 2020 at 16:04, Jonas Krauss <jkraus...@gmail.com> wrote:
>
>> Hi all,
>>
>> we are running Storm 2.2.0 on openjdk build
>> 1.8.0_272-8u272-b10-0+deb9u1-b10 in a cluster with five supervisors. We are
>> trying to set individual worker child options for a topology via the Java
>> Config object like so:
>>
>> Config conf = new Config();
>> conf.put(Config.WORKER_CHILDOPTS, "-Xmx%HEAP-MEM%m -XX:+UseG1GC");
>>
>> Looking at the java processes of the topology on the cluster, we do not
>> see the JVM options to be present, e.g. the string -XX:+UseG1GC is not
>> found anywhere in htop. However, when submitting the topology everything
>> seems fine, as the options are printed from the storm submitter:
>>
>> 13:15:01.939 [main] INFO o.a.s.StormSubmitter - Submitting topology
>> test_topology in distributed mode with conf
>> {...,"worker.childopts":"-Xmx%HEAP-MEM%m
>> -XX:+UseG1GC",...}
>>
>> Any idea why this is not working?
>>
>> Thanks
>>
>> Jonas
>>
>
