Не удается отправить топологию Storm / начало работы) - PullRequest
1 голос
/ 21 мая 2019

Я пытаюсь начать с Storm.Я установил размещенный кластер.Для начала я выполнил все шаги, перечисленные здесь .Он работает до отправки:

storm jar target/storm-starter-*.jar org.apache.storm.starter.RollingTopWords production-topology не удается с

Running: java -client -Ddaemon.name= -Dstorm.options= -Dstorm.home=/usr/local/Cellar/storm/1.2.2/libexec -Dstorm.log.dir=/usr/local/Cellar/storm/1.2.2/libexec/logs -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib -Dstorm.conf.file= -cp /usr/local/Cellar/storm/1.2.2/libexec/*:/usr/local/Cellar/storm/1.2.2/libexec/lib/*:/usr/local/Cellar/storm/1.2.2/libexec/extlib/*:target/storm-starter-2.0.1-SNAPSHOT.jar:/usr/local/Cellar/storm/1.2.2/libexec/conf:/usr/local/Cellar/storm/1.2.2/libexec/bin -Dstorm.jar=target/storm-starter-2.0.1-SNAPSHOT.jar -Dstorm.dependency.jars= -Dstorm.dependency.artifacts={} org.apache.storm.starter.RollingTopWords production-topology
Error: Could not find or load main class org.apache.storm.starter.RollingTopWords
Caused by: java.lang.NoClassDefFoundError: org/apache/storm/topology/ConfigurableTopology

Я не знаком с Java и Storm, но начать работу пока не очень хорошо.

1 Ответ

1 голос
/ 21 мая 2019

ConfigurableTopology не существует в Storm 1.2.2.Скорее всего, вы пытаетесь использовать банку для штормовых стартеров, созданную из Storm 2.x с кластером 1.2.2.Это не будет работать.Вместо этого постройте шторм-стартер из источников 1.x, и он должен работать.

...