java - 启动多语言子进程时出现 Storm 错误

Question

当我使用 storm (StormCpp) 的 cpp 包装器时，我遇到了一个 storm 错误，它使用了 ShellBolt 的多语言子进程，这个给了我下一个错误:

10784 [Thread-17-split] ERROR backtype.storm.util - Async loop died! java.lang.RuntimeException: Error when launching multilang subprocess

这是我的拓扑 Java 代码:

public class AppCppStorm {
public static class CppStorm extends ShellBolt implements IRichBolt {

    public CppStorm()
    {
        super("test");
    }

    @Override
    public void declareOutputFields(OutputFieldsDeclarer declarer) {}

    @Override
    public Map<String, Object> getComponentConfiguration() {
        return null;
    }
}
public static void main(String[] args) throws Exception {

    TopologyBuilder builder = new TopologyBuilder();

    builder.setSpout("spout", new RandomSentenceSpout());

    builder.setBolt("split", new CppStorm())
            .shuffleGrouping("spout");


    Config conf = new Config();
    conf.setDebug(true);

    conf.setNumWorkers(3);
    conf.setMaxTaskParallelism(3);

    LocalCluster cluster = new LocalCluster();
    cluster.submitTopology("test", conf, builder.createTopology());

    Thread.sleep(10000);

    cluster.shutdown();

}
}

如果有人能在这一点上帮助我，我将不胜感激。

Answer 1

我发现了错误，我没有放入我的 ShellBolt 的实例化，即我的 Bolt Cpp 应用程序的绝对路径。