Which "storm.yaml" file did you change? Each supervisor has it's own copy of it (at least usually; or do you have a NFS and storm.yaml is shared over all nodes in the cluster?), and you need to change it in all of them.
Not sure, why the value of your Config object did not get picked up...
Did you try "topology.worker.childopts", too?
-Matthias
On 04/16/2016 11:10 PM, sam mohel wrote:
> Thanks for you both
> but it didn't read what i wrote
> i tried im storm.yaml
> worker.childopts: "-Xms4g -Djava.net.preferIPv4Stack=true"
> but it read "worker.childopts" "-Xmx768m" and i noticed
> topology.worker.childopts" nil
>
> what is the difference between them ?
>
> i tried to set it in the code by
> conf.put("worker.childopts","-Xms4g"); but still read same size
>
> How can i make my change be readen as i set ?
>
> On Sat, Apr 16, 2016 at 2:37 PM, Andrey Dudin <doodin...@gmail.com
> <mailto:doodin...@gmail.com>> wrote:
>
> |-Xms<size>set initial Javaheap size -Xmx<size>set maximum Javaheap size|
>
> Now you have maximum heap size 2048m. If you need to increase heap
> size, delete -Xmx2048m and add -Xms4G
>
> 2016-04-16 14:03 GMT+03:00 sam mohel <sammoh...@gmail.com
> <mailto:sammoh...@gmail.com>>:
>
> i have this in storm.yaml
> worker.childopts: "-Xmx2048m -XX:MaxPermSize=256m
> -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -verbose:gc
> -Xloggc:/usr/local/storm/logs/gc-storm-worker-%6700%.log"
>
> what should i write in this statement ?
>
>
> On Saturday, April 16, 2016, Andrey Dudin <doodin...@gmail.com
> <mailto:doodin...@gmail.com>> wrote:
>
> >i want to increase size of heap for worker to -Xms4G how can i
> write it in storm.yaml ?
>
> add this option to worker.childopts
>
> 2016-04-16 7:34 GMT+03:00 sam mohel <sammoh...@gmail.com>:
>
> i want to increase size of heap for worker to -Xms4G how
> can i write it in storm.yaml ?
>
> and how can i set the number of CPU consuming bolts to
> the amount of cores ?
>
> Thanks for any help
>
>
>
>
> --
> С уважением Дудин Андрей
>
>
>
>
> --
> С уважением Дудин Андрей
>
>
signature.asc
Description: OpenPGP digital signature
