我是新来的风暴,当我提交了一个拓扑管理员日志已经
still hasn't start
配置是
tickTime=2000
dataDir=/tmp/zookeeper
clientPort=2181
syncLimit=5
initLimit=10
zookeeper的版本是 3.4.5
我在用 java version "1.6.0_38" Java(TM) SE Runtime Environment (build 1.6.0_38-b05) Java HotSpot(TM) Client VM (build 20.13-b02, mixed mode, sharing)
风暴.yaml
########### These MUST be filled in for a storm configuration
storm.zookeeper.servers: - "localhost"
storm.zookeeper.port: 2181
supervisor.slots.ports:
- 6700
- 6701
- 6702
- 6703
nimbus.thrift.max_buffer_size: 20480000
drpc.port: 3772
drpc.worker.threads: 64
drpc.max_buffer_size: 1048576
我先通过运行zookeeper提交了拓扑
1- storm/nimbus
2- storm/supervisor
3- storm/drpc
4-storm/ui
这里是storm ui
结果喷口不能发出消息和螺栓太有什么我可以分享它来解决这个问题?谁能帮忙?!
2条答案
按热度按时间4nkexdtk1#
我也有同样的问题。在我的例子中,由于拓扑jar中的jar文件和supervisor节点(在storm/lib/folder中)中的jar文件之间的类不兼容,所以supervisor没有启动。请在主管节点中检查日志文件并发布它们。尽管监视程序显示在storm ui中,但它可能没有启动。
fhg3lkii2#
抱歉,迟了答复,问题是我的代码。我使用的是trident和drpc,我没有编写drpc客户端代码