You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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