Я пытаюсь настроить среду Apache Samza и Kafka. Я испытываю некоторые проблемы при попытке запустить модули.
У меня Кафка работает правильно, но Самзу заставить работать не могу. Я установил две коробки Debian Jeesy AMD64 и следовал инструкциям документации Samza:
apt-get install openjdk-7-jdk openjdk-7-jre git maven
git clone http://git-wip-us.apache.org/repos/asf/samza.git
cd samza
./gradlew clean build
Когда я пытаюсь запустить скрипт, который должен запускать Yarn AppMaster со скриптом, поставляемым с Samza:
/opt/samza/samza-shell/src/main/bash/run-am.sh
Я получаю эту ошибку:
Error: Main class org.apache.samza.job.yarn.SamzaAppMaster has not been found or loaded
Если я попытаюсь запустить тестовое задание с помощью сценария run-job.sh
./run-job.sh --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory --config-path=file://$PWD/deploy/samza/config/wikipedia-feed.properties
и я получаю аналогичную ошибку со ссылкой на класс org.apache.samza.job.JobRunner.
Я думаю, что у меня проблема с конфигурацией Java, но я не могу найти много помощи или ссылок.
Кто-нибудь знает, что я делаю неправильно?
