org.apache.storm.multilang.NoOutputException：管道到子进程似乎被破坏！蟒蛇：无法打开文件[错误2]没有这样的文件或目录

Question

每当我尝试在本地运行我的风暴拓扑我得到以下

错误： 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文件时，我可以在资源文件夹中看到相应的python文件，但在部署jar时无法从拓扑中找到python文件。

Answer 1

我也有与我创建的Python螺栓相同的错误。我的问题是我忘记调用Python代码底部的类。下面的示例代码。

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() 

示例代码的最后一行是我忘记放入的内容，从而导致错误。确保你有。