Storm：服务器 mk-supervisor 初始化错误-必填字段 'serialized_parts' 未设置错误

Question

我尝试安装最新版本的 storm，storm 0.10.beta1 apache-storm-0.10.0-beta1.tar.gz

并使用以下 supervisord 脚本启动 supervisor，但我得到了 TProtocolException: Required field 'serialized_parts' is unset error。

[program:storm-supervisor]
command=/home/prod/softwares/storm/bin/storm supervisor
autostart=true  
autorestart=true  
startsecs=10 
startretries=999  
kill_as_group=true

Storm.yaml

storm.zookeepereeper.servers:
        - "192.168.10.30"
        storm.zookeeper.port: 2181
        storm.local.dir: "localdir"
        nimbus.host: "192.168.10.30"
        supervisor.slots.ports:
               - 6700
        ui.port: 8080

有人知道为什么会出现这样的错误吗？异常调用堆栈如下所示

Caused by: org.apache.thrift7.protocol.TProtocolException: Required field 'serialized_parts' is unset! Struct:LocalStateData(serialized_parts:null)
        at backtype.storm.generated.LocalStateData.validate(LocalStateData.java:336) ~[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at backtype.storm.generated.LocalStateData$LocalStateDataStandardScheme.read(LocalStateData.java:403) ~[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at backtype.storm.generated.LocalStateData$LocalStateDataStandardScheme.read(LocalStateData.java:364) ~[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at backtype.storm.generated.LocalStateData.read(LocalStateData.java:310) ~[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at org.apache.thrift7.TDeserializer.deserialize(TDeserializer.java:81) ~[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at org.apache.thrift7.TDeserializer.deserialize(TDeserializer.java:67) ~[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at backtype.storm.utils.LocalState.partialDeserializeLatestVersion(LocalState.java:100) ~[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at backtype.storm.utils.LocalState.partialSnapshot(LocalState.java:114) ~[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        ... 14 more
2015-06-25 09:18:33.392 b.s.util [ERROR] Halting process: ("Error on initialization")
java.lang.RuntimeException: ("Error on initialization")
        at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:332) [storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.6.0.jar:?]
        at backtype.storm.daemon.supervisor$fn__5519$mk_supervisor__5546.doInvoke(supervisor.clj:495) [storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at clojure.lang.RestFn.invoke(RestFn.java:436) [clojure-1.6.0.jar:?]
        at backtype.storm.daemon.supervisor$_launch.invoke(supervisor.clj:782) [storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at backtype.storm.daemon.supervisor$_main.invoke(supervisor.clj:813) [storm-core-0.10.0-beta1.jar:0.10.0-beta1]
        at clojure.lang.AFn.applyToHelper(AFn.java:152) [clojure-1.6.0.jar:?]
        at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.6.0.jar:?]
        at backtype.storm.daemon.supervisor.main(Unknown Source) [storm-core-0.10.0-beta1.jar:0.10.0-beta1]

Answer 1

这可能是因为中断运行，您在 /storm-local 目录中遗留了一些内容。删除 /storm-local 目录后重新启动主管。

Storm：服务器 mk-supervisor 初始化错误-必填字段 'serialized_parts' 未设置错误

Storm: Error on initialization of server mk-supervisor- Required field 'serialized_parts' is unset error

apache-storm