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
{{ message }}
This repository has been archived by the owner on Apr 18, 2018. It is now read-only.
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
The text was updated successfully, but these errors were encountered:
Sign up for freeto subscribe to this conversation on GitHub.
Already have an account?
Sign in.
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
The text was updated successfully, but these errors were encountered: