伺服器意外重新開機導緻storm報錯的問題處理

解決方法

cat /opt/storm-0.8.2/conf/storm.yaml中找到storm.local.dir設定的目錄，備份supervisor和workers兩個檔案夾，

#nohup supervise /service/storm/ &

重新開機

錯誤如下

2014-06-17 12:27:05,267 INFO [main] daemon.supervisor (NO_SOURCE_FILE:invoke(0)) - Starting supervisor with id xxx at host hadoop02

2014-06-17 12:27:05,124 ERROR [Thread-2] storm.event (NO_SOURCE_FILE:invoke(0)) - Error when processing event

java.lang.RuntimeException: java.io.EOFException

at backtype.storm.utils.Utils.deserialize(Utils.java:68)

at backtype.storm.utils.LocalState.snapshot(LocalState.java:28)

at backtype.storm.utils.LocalState.get(LocalState.java:39)

at backtype.storm.daemon.supervisor

$sync_processes.invoke(supervisor.clj:187) at clojure.lang.AFn.applyToHelper(AFn.java:161) at clojure.lang.AFn.applyTo(AFn.java:151) at clojure.core$

apply.invoke(core.clj:603)

at clojure.corepartialfn4070.doInvoke(core.clj:2343)

at clojure.lang.RestFn.invoke(RestFn.java:397)

at backtype.storm.eventeventmanagerfn3058.invoke(event.clj:24)

at clojure.lang.AFn.run(AFn.java:24)

at java.lang.Thread.run(Thread.java:662)

Caused by: java.io.EOFException

at java.io.ObjectInputStream

$PeekInputStream.readFully(ObjectInputStream.java:2284) at java.io.ObjectInputStream$

BlockDataInputStream.readShort(ObjectInputStream.java:2753)

at java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:777)

at java.io.ObjectInputStream.<init>(ObjectInputStream.java:277)

at backtype.storm.utils.Utils.deserialize(Utils.java:63)

... 11 more

2014-06-17 12:27:05,124 INFO [Thread-2] storm.util (NO_SOURCE_FILE:invoke(0)) - Halting process: ("Error when processing an event")

--EOF--

作者：Buro#79xxd

出處：http://www.cnblogs.com/buro79xxd/

文章版權歸本人所有，歡迎轉載，但未經作者同意必須保留此段聲明，且在文章頁面明顯位置給出原文連接配接，否則保留追究法律責任的權利。