storm执行报错

storm集群下执行bin/storm jar examples/storm-starter/storm-starter-topologies-0.10.0.jar  storm.starter.WordCountTopology,
报错信息:19173 [Thread-32] ERROR b.s.t.ShellBolt - Halting process: ShellBolt died. Command: [python, splitsentence.py], ProcessInfo pid:17487, name:split exitCode:-1, errorString:(Unable to capture e
rror stream) java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read.
Serializer Exception:
(Unable to capture error stream)

    at backtype.storm.utils.ShellProcess.readShellMsg(ShellProcess.java:101) ~[storm-core-0.10.0.jar:0.10.0]
    at backtype.storm.task.ShellBolt$BoltReaderRunnable.run(ShellBolt.java:321) [storm-core-0.10.0.jar:0.10.0]
    at java.lang.Thread.run(Thread.java:745) [?:1.8.0_77]
而且在web ui里看不到topology的信息

wemike

赞同来自:

问题找到了ShellBolt died. Command: [python, splitsentence.py], ProcessInfo pid:18459, name:split exitCode:-1, errorString:(Unable to capture e rror stream) ,这个日志说明是splitsentence.py这个文件找不到,这个文件的目录在jar包下的resource目录下,我把这个文件拷贝到WordCountTopologyNode.class同级目录下也不可以访问,该如何是好呢!!!请大神帮忙

wemike

赞同来自:

用java把代码重写了,没用他的代码,正常运行

要回复问题请先登录注册