| ########### These all have default values as shown |
| ########### Additional configuration goes into storm.yaml |
| |
| java.library.path: "/usr/local/lib:/opt/local/lib:/usr/lib" |
| |
| ### storm.* configs are general configurations |
| # the local dir is where jars are kept |
| storm.local.dir: "/mnt/storm" |
| storm.zookeeper.port: 2181 |
| storm.zookeeper.root: "/storm" |
| storm.zookeeper.session.timeout: 10000 |
| storm.cluster.mode: "distributed" # can be distributed or local |
| storm.local.mode.zmq: false |
| |
| ### nimbus.* configs are for the master |
| nimbus.thrift.port: 6627 |
| nimbus.childopts: "-Xmx1024m" |
| nimbus.task.timeout.secs: 30 |
| nimbus.supervisor.timeout.secs: 60 |
| nimbus.monitor.freq.secs: 10 |
| nimbus.task.launch.secs: 90 |
| nimbus.reassign: true |
| nimbus.file.copy.expiration.secs: 600 |
| |
| ### supervisor.* configs are for node supervisors |
| # Define the amount of workers that can be run on this machine. Each worker is assigned a port to use for communication |
| supervisor.slots.ports: |
| - 6700 |
| - 6701 |
| - 6702 |
| - 6703 |
| supervisor.childopts: "-Xmx1024m" |
| #how long supervisor will wait to ensure that a worker process is started |
| supervisor.worker.start.timeout.secs: 20 |
| #how long between heartbeats until supervisor considers that worker dead and tries to restart it |
| supervisor.worker.timeout.secs: 25 |
| #how frequently the supervisor checks on the status of the processes it's monitoring and restarts if necessary |
| supervisor.monitor.frequency.secs: 3 |
| #how frequently the supervisor heartbeats to the cluster state (for nimbus) |
| supervisor.heartbeat.frequency.secs: 5 |
| supervisor.enable: true |
| |
| ### worker.* configs are for task workers |
| worker.childopts: "-Xmx768m" |
| worker.heartbeat.frequency.secs: 1 |
| |
| task.heartbeat.frequency.secs: 3 |
| task.refresh.poll.secs: 10 |
| |
| zmq.threads: 1 |
| zmq.linger.millis: 5000 |
| |
| ### topology.* configs are for specific executing storms |
| topology.debug: false |
| topology.optimize: true |
| topology.workers: 1 |
| topology.ackers: 1 |
| # maximum amount of time a message has to complete before it's considered failed |
| topology.message.timeout.secs: 30 |
| topology.skip.missing.serializations: false |
| topology.max.task.parallelism: null |
| topology.max.spout.pending: null |
| topology.state.synchronization.timeout.secs: 60 |
| topology.stats.sample.rate: 0.05 |
| |
