apache风暴螺栓++

2skhul33  于 2021-06-21  发布在  Storm
关注(0)|答案(0)|浏览(245)

我是Apache风暴的新手。我正在尝试用c++编写螺栓。我引用了这个链接并尝试运行wordcounttopology示例。螺栓在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"); 任何帮助都将不胜感激。谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题