Ява Apache Storm Bolt в переполнении стека

Я новичок в Apache Storm. Я пытаюсь написать болты в C ++. Я сослался на этот ссылку и попытался запустить пример WordCountTopology. Болт splitsentence находится в cpp. Но когда я отправляю jar на кластер (локальный), я получаю следующую ошибку:

2016-12-15 20:22:16.911 o.a.s.util [ERROR] Async loop died!

java.lang.RuntimeException: org.apache.storm.multilang.NoOutputException: канал к подпроцессу, кажется, сломан! Нет вывода читать.

Исключение сериализатора:

at org.apache.storm.utils.ShellProcess.launch(ShellProcess.java:91) ~[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.task.ShellBolt.prepare(ShellBolt.java:131) ~[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.daemon.executor$fn__8058$fn__8071.invoke(executor.clj:795) ~[storm-core-1.0.2.jar:1.0.2]
at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:482) [storm-core-1.0.2.jar:1.0.2]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.7.0_121]
2016-12-15 20:22:16.912 o.a.s.d.executor [ERROR]

Единственная разница между моим SentenceSplitTest.java и ссылкой из ссылки заключается в вызове super ():
Мой читает: super("g++","SplitSentenceTest.cpp","Storm.cpp","jsoncpp.cpp");

Любая помощь будет оценена. Спасибо.

1

Решение

Задача ещё не решена.

Другие решения

Других решений пока нет …