重启集群也没有用,想到可能是zookeeper中有冲突,删除了/storm中的所有,一启动,发现还是这样。检查了配置,也没有不对的地方。接着检查日志,发现两个supervisor用的都是同一个id,随后检查zk,/storm/supervisors/下面也是一样的id。似乎发现问题了。

 

google了一把,发现了nathanmarz之前解答过这个问题,https://groups.google.com/forum/#!topic/storm-user/pheWVv_3JZ4

 

他的说法是:

Delete the local dirs on the supervisors. They’ll generate new ids for themselves.

 

在删除了local dir,重启后恢复了。后来回想起来,是因为这个集群是拿线上的环境scp的,可能残留了local dir的东西,然后storm是根据local dir中的某一个或一些文件计算出一个supervisor id的。删除local dir后,会重新生成id。

Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐