#elasticsearch #apache-storm
#elasticsearch #apache-storm
Вопрос:
Я хочу использовать storm в качестве решения для обработки событий. Я хочу пересылать события из ELK в storm и добавлять некоторый код в storm.
Я пытался запустить код запуска storm: https://github.com/apache/storm/tree/master/examples/storm-starter
использую Intellij IDEA, но я продолжаю получать сообщение об ошибке об отсутствующем классе: org.apache.storm.localcluster
не могли бы вы помочь с этим? я использую правильный код? Я был бы очень признателен за вашу помощь в этом
Ответ №1:
Просто копирую то, что я ответил в список рассылки пользователей: файлы, сгенерированные thrift, сложны. Пожалуйста, попробуйте mvn clean install -DskipTests root каталога Storm и вернитесь к IDEA и посмотрите, что это помогает.
Комментарии:
1. Я сделал, теперь я получаю эту ошибку: исключение в потоке «main» java.lang. Ошибка NoClassDefFoundError: org/apache/storm/topology/IRichSpout на java.lang. Class.forName0(собственный метод) в java.lang. Class.forName(Class.java:264) в com.intellij.rt.execution.application. AppMain.main(AppMain.java:123), вызванный: java.lang. Исключение ClassNotFoundException: org.apache.storm.topology. IRichSpout в java.net.URLClassLoader.FindClass(URLClassLoader.java:381) в java.lang. ClassLoader.loadClass(ClassLoader.java: 424) в sun.misc. Launcher $AppClassLoader.loadClass(Launcher.java: 331) в java.lang. ClassLoader.loadClass…