hadoop log4j找不到kafkalog4jappender.class

yqlxgs2m 于 2021-05-29 发布在 Hadoop

关注(0)|答案(1)|浏览(331)

我在mr工作中添加了kafkalog4jappender功能。本地作业正在运行，并将格式化的日志发送到我的kafka集群。
当我尝试从yarn服务器运行它时，使用：

jar [jar-name].jar [DriverClass].class [job-params] -Dlog4j.configuration=log4j.xml -libjars

我得到以下解释：

log4j:ERROR Could not create an Appender. Reported error follows.
java.lang.ClassNotFoundException: kafka.producer.KafkaLog4jAppender

kafkalog4jappender类在路径中。跑步

jar tvf [my-jar].jar | grep KafkaLog4J

查找类
我有点迷路了，如果你能给我一些有用的建议，我会很感激的
提前谢谢！

1条答案

如果它在本地模式下工作，而不是在Yarn/分布模式下工作，则可能是jar分布不正确的问题。您可能希望检查在mapreduce应用程序（分布式缓存）中使用第三部分jar和文件，以了解有关如何分发包含kafkalog4jappender.class的jar的详细信息