Storm 1.2.2 Supervisor 也将 localhost 作为 nimbus 并且无法连接到它，尽管 nimbus 在另一个服务器中并且已经在 Storm.yaml 中指定 [英] Storm 1.2.2 Supervisor also take localhost as nimbus and can't connect to it, although nimbus is in another server and already specified in storm.yaml

问题描述

问题和标题一样，集群启动后管理日志中没有打印错误.每次提交jar时，在supervisors的日志中都会报连接localhost nimbus失败的错误.

problem is just as titled, no errors printed in supervisor logs after cluster is started. whenever a jar is submitted, error is reported in supervistors' log that fail to connect localhost nimbus.

1，这是我的 yaml:

1, here is my yaml:

storm.zookeeper.servers:
    - "beta-hbase02"
    - "beta-hbase03"
    - "beta-hbase04"
storm.zookeeper.root: "/storm"
nibus.seeds: ["beta-hbase01"]
storm.local.dir: "/var/lib/hadoop-hdfs/apache-storm/storm/data"
supervisor.slots.ports:
    - 6800
    - 6801
    - 6802
    - 6803
ui.port: 8686
storm.log.dir: "/var/lib/hadoop-hdfs/apache-storm/logs"
worker.childopts: "-Xmx1024m"
nimbus.childopts: "-Xmx2048m"

2、这里是supervisor.log的错误，不是access-supervisor.log

2, here is the error in supervisor.log, nother in access-supervisor.log

2018-08-21 17:10:23.643 o.a.s.l.AsyncLocalizer Async Localizer [WARN] Caught Exception While Downloading (rethrowing)... 
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:120) ~[storm-core-1.2.2.jar:1.2.2]
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:66) ~[storm-core-1.2.2.jar:1.2.2]
    at org.apache.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:58) ~[storm-core-1.2.2.jar:1.2.2]
    at org.apache.storm.blobstore.NimbusBlobStore.prepare(NimbusBlobStore.java:268) ~[storm-core-1.2.2.jar:1.2.2]
    at org.apache.storm.utils.Utils.getClientBlobStoreForSupervisor(Utils.java:539) ~[storm-core-1.2.2.jar:1.2.2]
    at org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.downloadBaseBlobs(AsyncLocalizer.java:121) ~[storm-core-1.2.2.jar:1.2.2]
    at org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.call(AsyncLocalizer.java:148) [storm-core-1.2.2.jar:1.2.2]
    at org.apache.storm.localizer.AsyncLocalizer$DownloadBaseBlobsDistributed.call(AsyncLocalizer.java:101) [storm-core-1.2.2.jar:1.2.2]
    at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_171]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_171]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_171]
    at java.lang.Thread.run(Thread.java:748) [?:1.8.0_171]

推荐答案

您拼错了nimbus.seeds".

You misspelled "nimbus.seeds".

这篇关于Storm 1.2.2 Supervisor 也将 localhost 作为 nimbus 并且无法连接到它，尽管 nimbus 在另一个服务器中并且已经在 Storm.yaml 中指定的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！