Spring-xd hdfs sink- 创建 bean 时出错

Spring-xd hdfs sink- Error Creating bean

spring-xd 中使用 hdfs 作为接收器部署流时出现以下异常。 创建名称为 'hadoopConf iguration': Invocation of init method failed; nested exception is java.lang.NoClassDefFoundError: org/apache/hadoop/mapred/JobConf

的 bean 时出错

我的 spring-xd 应用程序 运行 已成功安装在 yarn 上。感谢您的帮助。

问题出在 servers.yml 的 siteMapreduceAppClassPath 中的配置。类路径应包括 hadoop-core jar 的路径,因为该 jar 不包含它给出 NoClassDefFoundError 的应用程序。