При отправке спарк-задания с использованием спарк-отправки данных сохранения пакета на пульсарную шину я получаю следующую проблему.
Исключение вызвала класс пользователя: java .lang.ClassNotFoundException: не удалось найти данные источник: pulsar Пожалуйста, найдите пакеты в http://spark.apache.org/third-party-projects.html java .lang.ClassNotFoundException: pulsar.DefaultSource
Я даю зависимости как --packages org. apache .pulsar: pulsar-client: 2.2.1 в команде spark submit Также я дал зависимости в pom. xml, а также для pulsar при создании файла JAR.
Я использую код в качестве формата (" Пульсар "), чтобы сохранить данные json в Пульсар.
Есть ли что-нибудь, что мне нужно посмотреть, чтобы решить проблему.
спасибо sarat