stormconf.ser在worker上不存在错误

mrfwxfqh  于 2021-06-21  发布在  Storm
关注(0)|答案(3)|浏览(227)

我有一个风暴群,有两个节点和一个zookeeper。其中一个工人死于以下错误。有人知道为什么stormconf.ser文件会被删除吗?
我使用的是0.9.2storm和3.4.6zk版本。

  1. o.a.c.f.s.ConnectionStateManager [INFO] State change: CONNECTED
  2. 2015-01-31 01:23:06 o.a.c.f.s.ConnectionStateManager [WARN] There are no ConnectionStateListeners registered.
  3. 2015-01-31 01:23:07 b.s.d.worker [ERROR] Error on initialization of server mk-worker
  4. java.io.FileNotFoundException: File '/home/Programs/apache-storm-0.9.2-incubating/stormtmp/supervisor/stormdist/storm-topology-1-1422602934/stormconf.ser' does not exist
  5. at org.apache.commons.io.FileUtils.openInputStream(FileUtils.java:299) ~[commons-io-2.4.jar:2.4]
  6. at org.apache.commons.io.FileUtils.readFileToByteArray(FileUtils.java:1763) ~[commons-io-2.4.jar:2.4]
  7. at backtype.storm.config$read_supervisor_storm_conf.invoke(config.clj:212) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
  8. at backtype.storm.daemon.worker$worker_data.invoke(worker.clj:180) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
  9. at backtype.storm.daemon.worker$fn__5940$exec_fn__1396__auto____5941.invoke(worker.clj:356) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
  10. at clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na]
  11. at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
  12. at clojure.core$apply.invoke(core.clj:617) ~[clojure-1.5.1.jar:na]
  13. at backtype.storm.daemon.worker$fn__5940$mk_worker__5996.doInvoke(worker.clj:347) [storm-core-0.9.2-incubating.jar:0.9.2-incubating]
  14. at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.5.1.jar:na]
  15. at backtype.storm.daemon.worker$_main.invoke(worker.clj:454) [storm-core-0.9.2-incubating.jar:0.9.2-incubating]
  16. at clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.5.1.jar:na]
  17. at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na]
  18. at backtype.storm.daemon.worker.main(Unknown Source) [storm-core-0.9.2-incubating.jar:0.9.2-incubating]
  19. 2015-01-31 01:23:07 b.s.util [INFO] Halting process: ("Error on initialization")
ha5z0ras

ha5z0ras1#

将hdp的版本降到2.5或更低使用StormVerion1.0.1它解决了这个问题。。。清除目录是没有用的主意。

bakd9h0s

bakd9h0s2#

这是旧版《暴风雪》中已知的问题。通常你需要做的是清除storm正在使用的目录。在storm的配置文件中检查这些文件的名称 conf/storm.yaml .

gopyfrb3

gopyfrb33#

只是想说明一下:这个问题似乎在Storm0.9.4中得到了解决。
@tousif链接的问题的详细信息:https://issues.apache.org/jira/browse/storm-130

相关问题