風暴異常：管道子流程似乎被打破

嗨我在生產服務器上設置風暴。運行supervisorctl status提供了以下outpug風暴異常：管道子流程似乎被打破

storm_nimbus      RUNNING pid 24955, uptime 15:51:16 
storm_supervisor     RUNNING pid 24953, uptime 15:51:16 
storm_ui       RUNNING pid 24956, uptime 15:51:16 
zookeeper      RUNNING pid 24954, uptime 15:51:16

的進程正在運行罰款然而，當我提出我的拓撲我得到這個錯誤

java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: Pipe to subprocess seems to be broken! No output read. Shell Process Exception: at backtype.storm.utils.Disruptor

我不知道爲什麼，因爲我的拓撲結構，做工精細發生這種情況時，我在本地運行。我如何追蹤這個錯誤的原因。我是新來的暴雨使...

詳細ERROR：

java.lang.RuntimeException: java.lang.RuntimeException: java.lang.RuntimeException: Pipe to subprocess seems to be broken! No output read. 
Shell Process Exception: 


    at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:87) 
    at backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:58) 
    at backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:62) 
    at backtype.storm.daemon.executor$fn__4050$fn__4059$fn__4106.invoke(executor.clj:658) 
    at backtype.storm.util$async_loop$fn__465.invoke(util.clj:377) 
    at clojure.lang.AFn.run(AFn.java:24) 
    at java.lang.Thread.run(Thread.java:701) 
Caused by: java.lang.RuntimeException: java.lang.RuntimeException: Pipe to subprocess seems to be broken! No output read. 
Shell Process Exception: 


    at backtype.storm.task.ShellBolt.execute(ShellBolt.java:139) 
    at backtype.storm.daemon.executor$fn__4050$tuple_action_fn__4052.invoke(executor.clj:566) 
    at backtype.storm.daemon.executor$mk_task_receiver$fn__3976.invoke(executor.clj:345) 
    at backtype.storm.disruptor$clojure_handler$reify__1606.onEvent(disruptor.clj:43) 
    at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:84) 
    ... 6 more 
Caused by: java.lang.RuntimeException: Pipe to subprocess seems to be broken! No output read. 
Shell Process Exception: 


    at backtype.storm.utils.ShellProcess.readString(ShellProcess.java:100) 
    at backtype.storm.utils.ShellProcess.readMessage(ShellProcess.java:62) 
    at backtype.storm.task.ShellBolt$1.run(ShellBolt.java:90) 
    ... 1 more

來源

2014-04-02 flexxxit

什麼是你的Storm版本？並正在使用Python來創建您的拓撲？ – Chiron

我正在使用風暴版本0.8.2和python 2.7。是的，我正在使用python來創建我的拓撲 – flexxxit

我檢查風暴工人日誌（../storm/logs/），並發現該問題是一個錯誤我的噴口編程。我引用的文件不存在問題現在已解決。無論如何感謝

來源

2014-04-05 07:57:09 flexxxit

風暴異常：管道子流程似乎被打破

回答

相關問題