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