backtype.storm.multilang.NoOutputException：管道到子進程似乎被破壞！沒有輸出讀取

我是新來的風暴使用python。我面臨着在本地模式下運行它的問題backtype.storm.multilang.NoOutputException：管道到子進程似乎被破壞！沒有輸出讀取

ERROR backtype.storm.util - Async loop died! 
java.lang.RuntimeException: backtype.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. 
Serializer Exception: 
usage: simbolt.py [-h] --data DATAPATH --pre PRECOMPPATH --res RESULT --inp 
        ORIGFILE 
simbolt.py: error: argument --data/-d is required

我無法弄清楚我該如何修復它或問題在哪裏？如果您需要任何東西我可以從代碼分享知道原因請告訴我

來源

2017-05-14 user5520049

首先你想做什麼？如果你正在調用一個子進程，我假設你正在嘗試使用傳入元組中接收到的數據從一個螺栓運行一個外部程序？如果是這樣，有更多的風暴（JVM）本地方式來做到這一點，但需要使用Java。

如果您正在使用Python和其他外部程序處理數據，並希望以分佈式方式執行此操作，那麼Storm可能不是您最好的選擇。使用類似Celery的東西可能會更好。然而，如果你想要Storm的所有優點，並且你可以重寫任何外部子進程在Python中做的事情，那麼StreamParse可能是一個不錯的選擇。

如果您可以提供更多關於您對子流程和整體拓撲的嘗試的信息，我可能會進一步提供幫助。首先是

來源

2017-05-15 16:18:54

。非常感謝回覆。我可以收到你的電子郵件嗎？ – user5520049

@ user5520049我寧可不要。你不能用你想要做什麼的簡單例子來更新你的文章嗎？ –

好的沒問題，我現在就編輯它。首先。我刪除了螺栓中的一些導入庫後，該錯誤消失了。但我需要執行的過程沒有完成。我將用更新編輯帖子 – user5520049

backtype.storm.multilang.NoOutputException：管道到子進程似乎被破壞！沒有輸出讀取

回答

相關問題