org.apache.storm.multilang.nooutputexception:到子进程的管道似乎已断开!python:无法打开文件[errno 2]没有这样的文件或目录

hlswsv35  于 2021-06-24  发布在  Storm
关注(0)|答案(1)|浏览(350)

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

hpcdzsge

hpcdzsge1#

我创建的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()

示例代码的最后一行是我忘记输入的代码,因此导致了错误。一定要有。

相关问题