本地模式可以执行成功
提交到yarn,报错
java.lang.ClassNotFoundException:org.apache.kafka.clients.consumer.ConsumerRecord


lib包里有sql-connector-kafka,请问这是什么情况导致的?可以怎么排查,yarn上有哪些jar包呢。

回复