Oh, I misread your intentions. Sorry about that. Glad you could solve it! Cheers
On Thu, Nov 19, 2020, 12:36 Jonas Krauss <[email protected]> wrote: > 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 <[email protected] > >: > >> 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 <[email protected]> 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 >>> >>
