2
Когда я пытаюсь протестировать STORM с использованием потокового теста yahoo, я получаю эти ошибки. Я попытался изменить порт на 2080 вместо стандартного порта 2181 в файле ZooKeeper zoo.cfg и kafka «server.properties». Тем не менее, я получаю ту же ошибку. Любая помощь приветствуется. Заранее спасибо. :-)Ошибка при попытке запустить STORM_TEST на потоковой скорости yahoo
2792 [main] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - binding to port 0.0.0.0/0.0.0.0:2181
2796 [main] ERROR o.a.s.s.o.a.z.s.NIOServerCnxnFactory - Thread Thread[main,5,main] died
java.lang.RuntimeException: No port is available to launch an inprocess zookeeper.
at org.apache.storm.zookeeper$mk_inprocess_zookeeper$fn__2124$fn__2126.invoke(zookeeper.clj:223) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.zookeeper$mk_inprocess_zookeeper$fn__2124.invoke(zookeeper.clj:219) ~[storm-core-1.0.1.jar:1.0.1]
at org.apache.storm.zookeeper$mk_inprocess_zookeeper.doInvoke(zookeeper.clj:217) ~[storm-core-1.0.1.jar:1.0.1]
at clojure.lang.RestFn.invoke(RestFn.java:439) ~[clojure-1.7.0.jar:?]
at org.apache.storm.command.dev_zookeeper$_main.doInvoke(dev_zookeeper.clj:25) ~[storm-core-1.0.1.jar:1.0.1]
at clojure.lang.RestFn.invoke(RestFn.java:397) ~[clojure-1.7.0.jar:?]
at clojure.lang.AFn.applyToHelper(AFn.java:152) ~[clojure-1.7.0.jar:?]
at clojure.lang.RestFn.applyTo(RestFn.java:132) ~[clojure-1.7.0.jar:?]
at org.apache.storm.command.dev_zookeeper.main(Unknown Source) ~[storm-core-1.0.1.jar:1.0.1]
Redis is already running...
WARNING: send already refers to: #'clojure.core/send in namespace: setup.core, being replaced by: #'clj-kafka.new.producer/send
{:redis-host localhost, :kakfa-brokers localhost:9092}
Writing campaigns data to Redis.
Error: Could not find or load main class .home.eranga.Software.kafka-0.10.0.1.config.server.properties
Unrecognized option: --create
Error: Could not create the Java Virtual Machine.
Error: A fatal exception has occurred. Program will exit.
Я нашел ответ на первый ERROR 'java.lang.RuntimeException: порт не доступен для запуска inprocess zookeeper.' Это происходит потому, что ZooKeeper уже запущен, прежде чем мы начнем тестирование эталона для Storm. Поэтому нам сначала нужно остановить ZooKeeper, используя следующие команды в терминале 'cd $ zookeeper_dir-version/bin /', а затем './zkServer.sh stop' –
Причина второй ошибки' Ошибка: не удалось найти или загрузить основной класс .home.eranga.Software.kafka-0.10.0.1.config.server.properties' было то, что я использовал исходную версию kafka. То, что я должен был использовать, было бинарной версией кафки. (Oops :-P Silly me) Итак, решение заключалось в том, чтобы загрузить двоичную версию и установить переменные пути для этой версии. Надеюсь, это поможет другим :-) –
Может быть, ваше решение в качестве ответа? –