Блог

Главная - Вопросы по программированию - Разъем Nats Spark: Ошибка: Не удалось загрузить класс

Разъем Nats Spark: Ошибка: Не удалось загрузить класс

#scala #apache-spark #intellij-idea #sbt #nats-streaming-server

Вопрос:

добрый день!

Я новичок в деле nats/spark и застрял на несколько дней. Было бы здорово получить любые чаевые. Я использую https://github.com/Logimethods/nats-connector-spark-scala соединитель для чтения сообщений с сервера nats. Я использую Intellij с SBT для его запуска, и он работает. Вместо этого, когда я пытаюсь создать файл de jar, происходит сбой:

введите описание изображения здесь

Я проверил, есть ли в файле jar МАНИФЕСТ.MF:

введите описание изображения здесь

Я думаю, что мне не хватает, возможно, некоторых проблем с зависимостью или несовместимостью, поэтому я прикреплю свой файл buildd.sbt:

 name := "brokerNatsSparkSBT"
version := "0.1"
scalaVersion := "2.11.12"

resolvers  = "Sonatype OSS Snapshots" at "https://oss.sonatype.org/content/repositories/snapshots"
resolvers  = "Sonatype OSS Release" at "https://oss.sonatype.org/content/groups/public/"

libraryDependencies  = "com.logimethods" % "nats-connector-spark-scala_2.11" % "1.0.0"

val sparkVersion = "2.3.1"

libraryDependencies   = Seq(
  "org.apache.spark" %% "spark-core" % sparkVersion,
  "org.apache.spark" %% "spark-streaming" % sparkVersion
)

Использование JDK 1.8, SBT в соответствии с build.properties 1.5.4.

Заранее спасибо!

Ответ №1:

После нескольких дней борьбы, в конце концов, я сделал это благодаря этой статье. Включая плагин sbt-assembly и создание с его помощью файла jar, который я получил для правильной сборки de jar.

Метки: