关于运行python(wordcounttopology)时storm中多语言的问题

2g32fytz  于 2021-06-24  发布在  Storm
关注(0)|答案(1)|浏览(303)

在运行自己的应用程序之前,我正在尝试以storm本地模式运行wordcounttopology,但无法运行它。我不断得到以下错误。我已经证实 splitsentence.py 文件保存在 multilang/resources 目录中的 examples/storm-starter 目录。

5729 [Thread-22-split-executor[7 7]] ERROR o.a.s.util - Async loop died!
java.lang.RuntimeException: org.apache.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read.
Serializer Exception:
python: can't open file 'splitsentence.py': [Errno 2] No such file or directory

        at org.apache.storm.utils.ShellProcess.launch(ShellProcess.java:91) ~[storm-core-1.0.3.jar:1.0.3]
        at org.apache.storm.task.ShellBolt.prepare(ShellBolt.java:131) ~[storm-core-1.0.3.jar:1.0.3]
        at org.apache.storm.daemon.executor$fn__4973$fn__4986.invoke(executor.clj:791) ~[storm-core-1.0.3.jar:1.0.3]
        at org.apache.storm.util$async_loop$fn__557.invoke(util.clj:482) [storm-core-1.0.3.jar:1.0.3]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:745) [?:1.8.0_51]
5734 [Thread-30-spout-executor[9 9]] INFO  o.a.s.d.executor - Opening spout spout:(9)
5734 [Thread-28-split-executor[6 6]] ERROR o.a.s.util - Async loop died!

我在安装过程中遵循了说明,并用maven成功地构建了我的包。我的storm版本是1.0.3,python版本是2.7.13。我运行了惊呼本体论和一些我自己的代码,这些代码不需要多语言支持,而且工作起来很有魅力。
我不明白为什么storm中的多语言支持不起作用。非常感谢您的帮助。

js5cn81o

js5cn81o1#

我的问题已经解决了。我只是想回复,让别人知道这个问题。我使用的是storm版本1.0.3,它有问题,下面提到了修复方法。
https://issues.apache.org/jira/browse/storm-2450
我将我的版本升级到一个修复版本,即1.0.4,它运行良好。

相关问题