阿帕奇风暴

Question

我们正在Java中运行storm拓扑。有一个使用Python脚本的bolt。为此，我们使用Multilang（ShellBolt）。当重新平衡发生在我们下面看到的拓扑中时

java.lang.RuntimeException: org.apache.storm.multilang.NoOutputException: Pipe to subprocess seems to be broken! No output read. Serializer Exception: at org.apache.storm.utils.ShellProcess.readShe

这是调用Python模型的代码

public pythoncallBolt(String pythonpath, String pythonfilepath) {
        super(pythonpath,pythonfilepath);

    }

任何人，请帮助我们解决这个问题