Storm 配置:设置worker进程内存大小

  • Post author:
  • Post category:其他



Storm中真正干活的是各个worker,而worker由supervisor负责启动。在topology启动过程中我们会看到如下的启动日志:


这就是启动一个worker进程,也就是一个JVM进程。

默认情况下,Storm启动worker进程时,JVM的最大内存是768M。

但我在使用过程中,由于会在Bolt中加载大量数据,768M内存无法满足需求,会导致内存溢出程序崩溃。

经过研究发现,可以通过在Strom的配置文件storm.yaml中设置worker的启动参数.



worker.childopts: "-Xmx2048m"




该参数会在启动时传递给JVM,然后就可以在worker中使用2048m内存了。


目前好像Storm还没有配置文件的详细说明,比如可以配置哪些参数,怎么配置?


大家可以先参考Storm源代码中的Config.java.



package backtype.storm;

http://www.sjsjw.com/kf_jiagou/article/81_12167_24001.asp