Storm error when starting multichannel subprocess

I have a storm error when I use the storm cpp (StormCpp) that use the ShellBolt multiprocessing subprocess and it gives me the following error:

10784 [Thread-17-split] ERROR backtype.storm.util - Async loop died! java.lang.RuntimeException: error while starting multichannel subprocess

This is my Java topology code:

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

}
}

      

If someone can help me with this issue, I would appreciate it.

+3


source to share


1 answer


I found an error, I did not include my ShellBolt Instanciation, the absolute path of my Bolt Cpp app.



0


source







All Articles