Version Info:
   "org.apache.storm" % "storm-core" % "1.2.1"
   "org.apache.storm" % "storm-kafka-client" % "1.2.1"

With this version of storm, when running topology, I see two processes for
each worker: one for logwriter and other for worker, as mentioned here
<https://stackoverflow.com/a/42517250/1610034> as well.

The problem is I want to give less memory to logwriter process(say
-Xmx512mb) and higher to worker process(say -Xmx12gb). But I am not able to
achieve this, I have tried playing with different config.

There is config topology.worker.logwriter.childopts, which is taken by
logwriter process, but than I have given some config to worker.childopts ,
but that also gets applied to both logwriter and worker process. Similary I
tried using topology.worker.childopts and that also gets applied to both
logwriter and worker process.

How to solve this to give lesser memory for logwriter process and higher
for worker process?

Best Regards

Saurabh Kumar Mimani

Reply via email to