我有两个拓扑。其中一个非常简单,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
暂无答案!
目前还没有任何答案,快来回答吧!