0

下午好!

我是 nats/spark 的新手,我已经被困了几天。任何小费都会很棒。我正在使用https://github.com/Logimethods/nats-connector-spark-scala连接器从 nats 服务器读取消息。我正在使用带有 SBT 的 Intellij 来运行它并且它可以工作。相反,当我尝试构建 de jar 文件失败时:

在此处输入图像描述

我检查了 jar 文件是否有 MANIFEST.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。

提前致谢!

4

1 回答 1

0

经过几天的苦苦挣扎,我终于做到了,这要归功于这篇文章。包括sbt-assembly插件并用它构建我实现正确构建的jar文件 de jar

于 2021-07-16T09:17:23.183 回答