У меня есть штормовая ошибка, когда я использую оболочку cpp для шторма (StormCpp), которая использует многоязыковой подпроцесс ShellBolt, и эта ошибка дает мне следующую ошибку:
10784 [Thread-17-split] ОШИБКА backtype.storm.util — Асинхронный цикл прерван!
java.lang.RuntimeException: ошибка при запуске многоязыкового подпроцесса
Это мой топологический код 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();
}
}
Если кто-то может помочь мне в этом вопросе, я был бы признателен.
Я нашел ошибку, я не вставил в свой экземпляр ShellBolt, абсолютный путь моего приложения Bolt Cpp.