Apache Samza および Kafka 環境をセットアップしようとしています。モジュールを実行しようとすると、いくつかの問題が発生します。
Kafka は正しく動作していますが、Samza を動作させることはできません。2 つの 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
Samza で提供されているスクリプトを使用して Yarn AppMaster を起動するスクリプトを起動しようとすると、次のようになります。
/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 の構成に問題があると考えていますが、ヘルプやリファレンスがあまり見つかりません。
私が間違っていることを誰かが知っていますか?