8.12. Known Issues for Storm

  • BUG-16232: Storm python support can use wrong version of python if supervisor host has more than one version of python installed.

    Problem: Storm requires the default system python interpreter to be version 2.6 or higher. Earlier versions of python can see this conflict.

    Workaround: Ensure that the default system python interpreter is version 2.6 or higher.

  • BUG-15960: Worker node gets 'FileNotFoundException : stormconf.ser'.

    Problem: While running Storm-HDFS topologies in a secure environment, the following error was observed in the worker node:

    2014-04-01 20:59:11 c.n.c.f.s.ConnectionStateManager [INFO] State change: CONNECTED 
    2014-04-01 20:59:11 c.n.c.f.s.ConnectionStateManager [WARN] There are no ConnectionStateListeners registered. 
    2014-04-01 20:59:11 b.s.d.worker [ERROR] Error on initialization of server mk-worker 
    java.io.FileNotFoundException: File '/home/storm/supervisor/stormdist/myPersistentWordCount-15-1396385521/stormconf.ser' does not exist 
    at org.apache.commons.io.FileUtils.openInputStream(FileUtils.java:299) ~[commons-io-2.4.jar:2.4] 
    at org.apache.commons.io.FileUtils.readFileToByteArray(FileUtils.java:1763) ~[commons-io-2.4.jar:2.4] 
    at backtype.storm.config$read_supervisor_storm_conf.invoke(config.clj:192) ~[storm-core-0.9.1.2.1.1.0-290.jar:0.9.1.2.1.1.0-290] 
    at backtype.storm.daemon.worker$worker_data.invoke(worker.clj:170) ~[storm-core-0.9.1.2.1.1.0-290.jar:0.9.1.2.1.1.0-290] 
    at backtype.storm.daemon.worker$eval4415$exec_fn__1103__auto____4416.invoke(worker.clj:353) ~[na:na] 
    at clojure.lang.AFn.applyToHelper(AFn.java:185) ~[clojure-1.4.0.jar:na] 
    at clojure.lang.AFn.applyTo(AFn.java:151) ~[clojure-1.4.0.jar:na] 
    at clojure.core$apply.invoke(core.clj:601) ~[clojure-1.4.0.jar:na] 
    at backtype.storm.daemon.worker$eval4415$mk_worker__4471.doInvoke(worker.clj:344) ~[na:na] 
    at clojure.lang.RestFn.invoke(RestFn.java:512) ~[clojure-1.4.0.jar:na] 
    at backtype.storm.daemon.worker$_main.invoke(worker.clj:454) ~[storm-core-0.9.1.2.1.1.0-290.jar:0.9.1.2.1.1.0-290] 
    at clojure.lang.AFn.applyToHelper(AFn.java:172) ~[clojure-1.4.0.jar:na] 
    at clojure.lang.AFn.applyTo(AFn.java:151) ~[clojure-1.4.0.jar:na] 
    at backtype.storm.daemon.worker.main(Unknown Source) ~[storm-core-0.9.1.2.1.1.0-290.jar:0.9.1.2.1.1.0-290] 
    2014-04-01 20:59:11 b.s.util [INFO] Halting process: ("Error on initialization")