每当我尝试在本地运行我的storm拓扑时,我都会得到以下结果
错误: java.lang.RuntimeException: org.apache.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: python: can't open file 'parser_bolt.py': [Errno 2] No such file or directory
我在网上到处搜索,但没能解决这个问题。解压编译后的jar时,我可以在resources文件夹中看到相应的python文件,但在部署jar时,却无法从拓扑中找到python文件。
1条答案
按热度按时间hpcdzsge1#
我创建的python螺栓也有同样的错误。我的问题是我忘了在python代码底部的类上调用run。下面的代码示例。
示例代码的最后一行是我忘记输入的代码,因此导致了错误。一定要有。