supervisor尚未启动

vsmadaxz  于 2021-06-21  发布在  Storm
关注(0)|答案(2)|浏览(298)

我是新来的风暴,当我提交了一个拓扑管理员日志已经

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

结果喷口不能发出消息和螺栓太有什么我可以分享它来解决这个问题?谁能帮忙?!

4nkexdtk

4nkexdtk1#

我也有同样的问题。在我的例子中,由于拓扑jar中的jar文件和supervisor节点(在storm/lib/folder中)中的jar文件之间的类不兼容,所以supervisor没有启动。请在主管节点中检查日志文件并发布它们。尽管监视程序显示在storm ui中,但它可能没有启动。

fhg3lkii

fhg3lkii2#

抱歉,迟了答复,问题是我的代码。我使用的是trident和drpc,我没有编写drpc客户端代码

相关问题