Как запустить класс Storm Topology через командную строку?

Привет, у меня есть один класс топологии с основным методом. Он запускает zookeeper и запускается в eclispe, щелкает правой кнопкой мыши и запускает как java-приложение. Но я пытаюсь запустить пакетный файл, который я пробовал

java -classpath jar-with-classes-and-dependency.jar com.demo.Topology

но это дает мне такое исключение.

Exception in thread "main" java.lang.NoClassDefFoundError:
backtype/storm/generated/AlreadyAliveException
        at java.lang.Class.getDeclaredMethods0(Native Method)
        at java.lang.Class.privateGetDeclaredMethods(Unknown Source)
        at java.lang.Class.getMethod0(Unknown Source)
        at java.lang.Class.getMethod(Unknown Source)
        at sun.launcher.LauncherHelper.getMainMethod(Unknown Source)
        at sun.launcher.LauncherHelper.checkAndLoadMain(Unknown Source) Caused by: java.lang.ClassNotFoundException:
backtype.storm.generated.AlreadyAliveException
        at java.net.URLClassLoader$1.run(Unknown Source)
        at java.net.URLClassLoader$1.run(Unknown Source)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(Unknown Source)
        at java.lang.ClassLoader.loadClass(Unknown Source)
        at sun.misc.Launcher$AppClassLoader.loadClass(Unknown Source)
        at java.lang.ClassLoader.loadClass(Unknown Source)

Я думаю, что это об отсутствии какой-либо зависимости. Пожалуйста, помогите запустить этот класс топологии.


batch-file topology apache-storm
person Swapnil1988    schedule 27.01.2015    source источник
comment
На самом деле я пытаюсь создать команду для запуска этой топологии с помощью пакетного файла.   -  person Swapnil1988    schedule 27.01.2015
comment
Опубликуйте свой метод main(), пожалуйста   -  person Chiron    schedule 27.01.2015

Ответы (1)


arrow_upward
2
arrow_downward

Попробуйте так побегать...

pathToStorm/bin/storm jar ./target/jar-with-classes-and-dependency.jar com.demo.Topology.

И помните, вы должны построить свою банку, прежде чем делать этот шаг. Вы можете создать свою банку, запустив mvn clean install внутри своего проекта storm, где находится ваш файл pom.xml.

person Community    schedule 05.02.2015