使用storm 2.2.0启动拓扑:无法从种子主机[localhost]中找到leader nimbus

cgh8pdjw  于 2021-06-24  发布在  Storm
关注(0)|答案(0)|浏览(403)

我正在使用storm 2.2.0,我的配置文件是:


# storm.yaml

storm.local.hostname: "10.100.7.109"

storm.zookeeper.servers:
    - "10.100.242.107"

nimbus.seeds: ["localhost"]

supervisor.slots.ports:    
    - 6701
    - 6702
    - 6703
    - 6704
    - 6705
    - 6706
    - 6707
    - 6708
    - 6709
    - 6710
    - 6711
    - 6712
    - 6713
    - 6714
    - 6715
    - 6716    
    - 6717

风暴光环工作正常,但当启动一个拓扑时,我有一个与之相关的错误 nimbus.seeds 配置:

20:58:05.488 [main] WARN  o.a.s.v.ConfigValidation - task.heartbeat.frequency.secs is a deprecated config please see class org.apache.storm.Config.TASK_HEARTBEAT_FREQUENCY_SECS for more information.
    20:58:05.563 [main] WARN  o.a.s.u.NimbusClient - Ignoring exception while trying to get leader nimbus info from localhost. will retry with a different seed host.
    org.apache.storm.thrift.TApplicationException: Internal error processing getLeader
    ...
    Exception in thread "main" org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader nimbus from seed hosts [localhost]. Did you specify a valid list of nimbus hosts for config nimbus.seeds?

运行命令时 storm list ,我收到相同的错误:

root@storm-nimbus-60:/usr/share/storm-2.2.0/conf# storm list
Running: /usr/lib/jvm/java-8-oracle/bin/java -client -Ddaemon.name= -Dstorm.options= -Dstorm.home=/usr/share/storm-2.2.0 -Dstorm.log.dir=/usr/share/storm-2.2.0/logs -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib:/usr/lib64 -Dstorm.conf.file= -cp /usr/share/storm-2.2.0/*:/usr/share/storm-2.2.0/lib/*:/usr/share/storm-2.2.0/extlib/*:/usr/share/storm-2.2.0/extlib-daemon/*:/usr/share/storm-2.2.0/conf:/usr/share/storm-2.2.0/bin org.apache.storm.command.ListTopologies
21:09:39.153 [main] INFO  o.a.s.v.ConfigValidation - Will use [class org.apache.storm.DaemonConfig, class org.apache.storm.Config] for validation
21:09:39.438 [main] WARN  o.a.s.v.ConfigValidation - task.heartbeat.frequency.secs is a deprecated config please see class org.apache.storm.Config.TASK_HEARTBEAT_FREQUENCY_SECS for more information.
21:09:39.669 [main] WARN  o.a.s.u.NimbusClient - Ignoring exception while trying to get leader nimbus info from localhost. will retry with a different seed host.
org.apache.storm.thrift.TApplicationException: Internal error processing getLeader
    at org.apache.storm.thrift.TServiceClient.receiveBase(TServiceClient.java:79) ~[storm-shaded-deps-2.2.0.jar:2.2.0]
    at org.apache.storm.generated.Nimbus$Client.recv_getLeader(Nimbus.java:1183) ~[storm-client-2.2.0.jar:2.2.0]
    at org.apache.storm.generated.Nimbus$Client.getLeader(Nimbus.java:1171) ~[storm-client-2.2.0.jar:2.2.0]
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:222) [storm-client-2.2.0.jar:2.2.0]
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:179) [storm-client-2.2.0.jar:2.2.0]
    at org.apache.storm.utils.NimbusClient.withConfiguredClient(NimbusClient.java:127) [storm-client-2.2.0.jar:2.2.0]
    at org.apache.storm.utils.NimbusClient.withConfiguredClient(NimbusClient.java:117) [storm-client-2.2.0.jar:2.2.0]
    at org.apache.storm.command.ListTopologies.main(ListTopologies.java:27) [storm-core-2.2.0.jar:2.2.0]
Exception in thread "main" org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader nimbus from seed hosts [localhost]. Did you specify a valid list of nimbus hosts for config nimbus.seeds?
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:250)
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:179)
    at org.apache.storm.utils.NimbusClient.withConfiguredClient(NimbusClient.java:127)
    at org.apache.storm.utils.NimbusClient.withConfiguredClient(NimbusClient.java:117)
    at org.apache.storm.command.ListTopologies.main(ListTopologies.java:27)

我的错误有什么解决办法吗?谢谢大家

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题