错误是：
java.lang.RuntimeException: Error when launching multilang subprocess
at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:105)
at backtype.storm.daemon.executor$fn__3493$fn__3505.invoke(executor.clj:689)
at backtype.storm.util$async_loop$fn__457.invoke(util.clj:431)
at clojure.lang.AFn.run(AFn.java:24)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.io.IOException: The pipe has been ended
at java.io.FileOutputStream.writeBytes(Native Method)
at java.io.FileOutputStream.write(FileOutputStream.java:260)
at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:65)
at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:123)
at java.io.DataOutputStream.flush(DataOutputStream.java:106)
at backtype.storm.utils.ShellProcess.writeString(ShellProcess.java:77)
at backtype.storm.utils.ShellProcess.writeMessage(ShellProcess.java:70)
at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:60)
at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:102)
... 4 more请帮助我如何恢复错误。并给出一个路径来与风暴工作。
谢谢，索米娅
1条答案
按热度按时间x759pob21#
确保在您尝试运行此程序的计算机中安装了python。wordcount拓扑使用
splitsentence.py它在运行python编写的bolt时似乎遇到了问题。如果你不打算和multilang你可以忽略这一点，应该没事。试着运行一个简单的，如果你要熟悉风暴如何工作。