Относительно проблемы с Multi-Lang в шторме при запуске Python (WordCountTopology)

Я пытаюсь запустить 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. Моя штормовая версия - 1.0.3, а моя версия на python - 2.7.13. Я запустил ExclamationTopology и некоторые из моего собственного кода, который не нуждается в многоязычной поддержке и работает как чудо.

Я не могу понять, почему многоязыковая поддержка в шторме не работает. Любая помощь в этом с благодарностью.

Источник

1 ответ

Моя проблема решена. Я просто хотел ответить, чтобы другие узнали о проблеме. Я использовал штормовую версию 1.0.3, которая имеет проблему, и исправление упоминается ниже.

https://issues.apache.org/jira/browse/STORM-2450

Я обновил свою версию до одной из версий исправления, то есть 1.0.4, и она работает нормально.

Источник
Другие вопросы по тегам