下午好!
我是 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。
提前致谢!