我设置了一个部署storm nimbus和另一个部署storm supervisor(和一个ui),但supervisor因为无法解析nimbus而死亡。。。它总是向pod fqdn注册自己:
2018-06-06 17:07:01.935 o.a.s.n.nimbusinfo主[信息]nimbus将其名称命名为storm-nimbus-hl874
如您所见,这是复制控制器中的pod名称,它不能被其他pod解析。。。
supervisor config为我创建的无头服务提供了正确的地址,该服务是可解析和可连接的,但一旦启动,它就会从zookeeper查询nimbus名称,即fqdn,忽略配置文件中的值(nimbus seeds)。所以我假设灵气种子实际上并不是告诉主管或用户界面在哪里找到灵气的一种方式。
不知道如何解决,或者是否有解决办法。
我可以创建一个带有无头服务的statefulset,其中pod和服务具有相同的名称,但这看起来非常难看。
1条答案
按热度按时间toe950271#
这是nimbus计算主机名的地方https://github.com/apache/storm/blob/c9b73a5e3ffcfc458772100dc6bd62ad1cf468de/storm-client/src/jvm/org/apache/storm/nimbus/nimbusinfo.java#l56
你应该可以设置https://github.com/apache/storm/blob/master/storm-client/src/jvm/org/apache/storm/config.java#l1108 覆盖它。