Storm Ошибка при запуске многоязыкового подпроцесса

У меня есть штормовая ошибка, когда я использую оболочку 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();

}
}

Если кто-то может помочь мне в этом вопросе, я был бы признателен.

3

Решение

Я нашел ошибку, я не вставил в свой экземпляр ShellBolt, абсолютный путь моего приложения Bolt Cpp.

0

Другие решения