You need to put any command line options for the worker in the conf/storm.yaml
file on all machines running the supervisors:
worker.childopts: "-Xmx1024m"
then restart the supervisors
From: [email protected] [mailto:[email protected]]
Sent: 15 October 2014 11:22
To: user
Subject: how can I set the worker jvm dynamically?
the jvm for my spout is too small, but when I set the jvm like this, it doesn't
work. so what's the correct way to do so ?
in my spout :
@Override
public Map<String, Object> getComponentConfiguration() {
Config conf = new Config();
//int tickFrequencyInSeconds = 10;
conf.put(Config.WORKER_CHILDOPTS, "-Xmx1024m");
return conf;
}