2

我正在尝试设置 Apache Samza 和 Kafka 环境。我在尝试运行模块时遇到了一些问题。

我让 Kafka 正常工作，但我无法让 Samza 工作。我已经安装了两个 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 配置问题，但我找不到太多帮助或参考。

有谁知道我做错了什么？

4

1 回答 1

1

仍然没有工作，但我已经领先了一步。从路径执行 Samza 提供的脚本时，它们希望位于 /bin/ 文件夹中，并且它们需要有一个 /lib/ 文件夹，所有 samza .jar 文件都应该位于该文件夹中。

我仍然有一些依赖问题，但不同的问题。

于 2015-03-13T12:44:38.447 回答