问题就像标题一样,集群启动后没有错误打印在supervisor日志中。每当提交jar时,supervistors的日志中都会报告无法连接本地主机nimbus的错误。
1,这是我的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中的错误
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]发布于 2018-08-21 21:56:44
你把"nimbus.seeds“拼错了。
https://stackoverflow.com/questions/51945443
复制相似问题