我的拓扑配置为使用14个工作线程,集群中当前有16个工作线程可用。但是当我提交拓扑时,storm ui上的“worker resources”部分显示所有14个worker都启动了,但是组件(拓扑组件)只分配给7个。其余显示不适用(见下面的快照)。
workers/supervisors日志文件没有显示任何有意义的错误,说明为什么没有为某些Worker分配组件。在过去的6个多小时里,我一直在谷歌上搜索,但没有结果
我的环境:
apache storm 2.1.0版
Zookeeper3.4.9
一个主节点(ubuntu 18.0.4 lts)
三个监控节点(ubuntu 18.0.4 lts)
1条答案
按热度按时间brtdzjyr1#
拓扑中每个组件(喷口和螺栓)的并行性提示是什么?如果它们加起来不超过14个,那么您就不会在所有工作进程上都有条目。
记住,您还可以设置系统组件的并行性,例如ackers和(在metricsv1中)metrics consumer。