storm本地群集工作,但stormsubmitter失败

vwkv1x7d  于 2021-06-21  发布在  Storm
关注(0)|答案(0)|浏览(237)

我有两个拓扑。其中一个非常简单,spout生成一个随机数,bolt将其保存在数据库中。此拓扑作为本地集群和使用提交到storm时都可以正常工作 StormSubmitter .
下一个虽然有点复杂,但遵循与上一个拓扑相同的代码模式。此拓扑在实现为 LocalCluster 但当我使用 StormSubmitter . 这失败的原因是什么?
我没有发现任何错误,但我在日志文件中看到了这一点

2015-07-16T11:24:59.376+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [1]
838 2015-07-16T11:25:09.532+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [2]
839 2015-07-16T11:25:19.702+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [3]
840 2015-07-16T11:25:29.837+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [4]
841 2015-07-16T11:25:40.010+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [5]
842 2015-07-16T11:25:50.187+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [6]
843 2015-07-16T11:26:00.442+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [7]
844 2015-07-16T11:26:10.760+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [8]
845 2015-07-16T11:26:21.174+0530 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-/192.168.1.117:6700... [9]

即使我检查了storm ui,拓扑也成功运行,但是没有打印任何本地日志。没有执行任何db操作。但是localcluster的一切都是按预期执行的。
编辑
风暴.yaml:

storm.zookeeper.servers:
   - "127.0.0.1"
 storm.zookeeper.port: 2181
 nimbus.host: "127.0.0.1"
 storm.local.dir: "/tmp/storm-data"
 java.library.path: "/usr/local/lib"
 storm.messaging.transport: backtype.storm.messaging.netty.Context
 supervisor.slots.ports:
      - 6700
      - 6701
      - 6702
      - 6703

暂无答案!

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

相关问题