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 

我无法弄清楚我该如何修复它或问题在哪里? 如果您需要任何东西我可以从代码分享知道原因请告诉我

首先你想做什么?如果你正在调用一个子进程,我假设你正在尝试使用传入元组中接收到的数据从一个螺栓运行一个外部程序?如果是这样,有更多的风暴(JVM)本地方式来做到这一点,但需要使用Java。

如果您正在使用Python和其他外部程序处理数据,并希望以分布式方式执行此操作,那么Storm可能不是您最好的选择。使用类似Celery的东西可能会更好。然而,如果你想要Storm的所有优点,并且你可以重写任何外部子进程在Python中做的事情,那么StreamParse可能是一个不错的选择。

如果您可以提供更多关于您对子流程和整体拓扑的尝试的信息,我可能会进一步提供帮助。首先是

+0

。非常感谢回复。我可以收到你的电子邮件吗? – user5520049

+0

@ user5520049我宁可不要。你不能用你想要做什么的简单例子来更新你的文章吗? –

+0

好的没问题,我现在就编辑它。首先 。我删除了螺栓中的一些导入库后,该错误消失了。但我需要执行的过程没有完成。我将用更新编辑帖子 – user5520049