environment：
OS:centos7
storm:apache-storm-0.9.4
pyleus:v0.3.0
I'am run word_count.jar.
but error in word_count_lines.log:
Exception in spout.run Traceback (most recent call last): File "/usr/lib/python2.7/site-packages/pyleus/storm/component.py", line 236, in run self.initialize_serializer() File "/usr/lib/python2.7/site-packages/pyleus/storm/component.py", line 191, in initialize_serializer raise ValueError("Unknown serializer: {0}", serializer) ValueError: ('Unknown serializer: {0}', None)
and watch storm monitor have an error:
java.lang.RuntimeException: Error when launching multilang subprocess Traceback (most recent call last): File "/usr/lib64/python2.7/runpy.py", line 162, in _run_module_as_main "__main__", fname, loader, pkg_name) File "/usr/lib64/python2.7/runpy.py", line 72, in _run_code exec code in run_globals File "/u01/storm/status/supervisor/stormdist/word_count-1-1459698468/resources/word_count/line_spout.py", line 4, in <module> from pyleus.storm import Spout ImportError: No module named pyleus.storm at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:66) at backtype.storm.spout.ShellSpout.open(ShellSpout.java:74) at backtype.storm.daemon.executor$fn__4654$fn__4669.invoke(executor.clj:522) at backtype.storm.util$async_loop$fn__458.invoke(util.clj:461) at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.EOFException at org.msgpack.io.StreamInput.readByte(StreamInput.java:60) at org.msgpack.unpacker.MessagePackUnpacker.getHeadByte(MessagePackUnpacker.java:66) at org.msgpack.unpacker.MessagePackUnpacker.trySkipNil(MessagePackUnpacker.java:396) at org.msgpack.template.MapTemplate.read(MapTemplate.java:59) at org.msgpack.template.MapTemplate.read(MapTemplate.java:27) at org.msgpack.template.AbstractTemplate.read(AbstractTemplate.java:31) at org.msgpack.MessagePack.read(MessagePack.java:527) at org.msgpack.MessagePack.read(MessagePack.java:496) at com.yelp.pyleus.serializer.MessagePackSerializer.readMessage(MessagePackSerializer.java:205) at com.yelp.pyleus.serializer.MessagePackSerializer.connect(MessagePackSerializer.java:67) at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:64) ... 5 more
environment： OS:centos7 storm:apache-storm-0.9.4 pyleus:v0.3.0 I'am run word_count.jar. but error in word_count_lines.log:
Exception in spout.run Traceback (most recent call last): File "/usr/lib/python2.7/site-packages/pyleus/storm/component.py", line 236, in run self.initialize_serializer() File "/usr/lib/python2.7/site-packages/pyleus/storm/component.py", line 191, in initialize_serializer raise ValueError("Unknown serializer: {0}", serializer) ValueError: ('Unknown serializer: {0}', None)and watch storm monitor have an error:java.lang.RuntimeException: Error when launching multilang subprocess Traceback (most recent call last): File "/usr/lib64/python2.7/runpy.py", line 162, in _run_module_as_main "__main__", fname, loader, pkg_name) File "/usr/lib64/python2.7/runpy.py", line 72, in _run_code exec code in run_globals File "/u01/storm/status/supervisor/stormdist/word_count-1-1459698468/resources/word_count/line_spout.py", line 4, in <module> from pyleus.storm import Spout ImportError: No module named pyleus.storm at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:66) at backtype.storm.spout.ShellSpout.open(ShellSpout.java:74) at backtype.storm.daemon.executor$fn__4654$fn__4669.invoke(executor.clj:522) at backtype.storm.util$async_loop$fn__458.invoke(util.clj:461) at clojure.lang.AFn.run(AFn.java:24) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.EOFException at org.msgpack.io.StreamInput.readByte(StreamInput.java:60) at org.msgpack.unpacker.MessagePackUnpacker.getHeadByte(MessagePackUnpacker.java:66) at org.msgpack.unpacker.MessagePackUnpacker.trySkipNil(MessagePackUnpacker.java:396) at org.msgpack.template.MapTemplate.read(MapTemplate.java:59) at org.msgpack.template.MapTemplate.read(MapTemplate.java:27) at org.msgpack.template.AbstractTemplate.read(AbstractTemplate.java:31) at org.msgpack.MessagePack.read(MessagePack.java:527) at org.msgpack.MessagePack.read(MessagePack.java:496) at com.yelp.pyleus.serializer.MessagePackSerializer.readMessage(MessagePackSerializer.java:205) at com.yelp.pyleus.serializer.MessagePackSerializer.connect(MessagePackSerializer.java:67) at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:64) ... 5 more