org.apache.storm网站.multilang.NoOutputException：指向子进程的管道似乎已断开！python:无法打开文件[Errno 2]没有这样的文件或目录

Question

每当我尝试在本地运行我的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文件。在

Answer 1

我也有同样的错误，我创建了一个Python螺栓。我的问题是我忘记在Python代码底部的类上调用run。下面是示例代码。在

import storm

class TestStuff(storm.BasicBolt)

     def initialize(self,conf,context):
          self._conf = conf;
          self._context = context;

     def process(self, tuple):
          storm.logInfo("test")

TestStuff().run()

示例代码的最后一行是我忘记输入的内容，因此导致了错误。一定要拿着。在