在生产模式下运行storm word count拓扑时,如果集群中只有一个节点示例,那么如果指定配置setnumworkers(3个);据我所知,每个工作进程都在单独的jvm示例上运行?。请澄清。
nhn9ugyo1#
如果查看supervisor节点的storm.yaml(或此处的默认值https://github.com/apache/storm/blob/1828a17e553927419d380203055803647aab2aa1/conf/defaults.yaml#l148),您将看到 supervisor.slots.ports 设置。此设置定义主管节点可以启动多少个工作进程(JVM),即主管提供的最大工作插槽数。在拓扑配置中设置的辅助进程数指定希望在其中运行拓扑的辅助进程插槽数。例如,如果您的supervisor config是默认值,那么它最多将启动4个worker,因为中列出了4个端口 supervisor.slots.ports . 如果你提交你的拓扑 config.setNumWorkers(3) ,主管将在主管计算机上启动3个工作JVM,占用4个插槽中的3个,并保留一个可用插槽。
supervisor.slots.ports
config.setNumWorkers(3)
1条答案
按热度按时间nhn9ugyo1#
如果查看supervisor节点的storm.yaml(或此处的默认值https://github.com/apache/storm/blob/1828a17e553927419d380203055803647aab2aa1/conf/defaults.yaml#l148),您将看到
supervisor.slots.ports
设置。此设置定义主管节点可以启动多少个工作进程(JVM),即主管提供的最大工作插槽数。在拓扑配置中设置的辅助进程数指定希望在其中运行拓扑的辅助进程插槽数。
例如,如果您的supervisor config是默认值,那么它最多将启动4个worker,因为中列出了4个端口
supervisor.slots.ports
. 如果你提交你的拓扑config.setNumWorkers(3)
,主管将在主管计算机上启动3个工作JVM,占用4个插槽中的3个,并保留一个可用插槽。