Alr*_*rio 5 scala sbt apache-spark
当我在终端运行时:
sudo Spark-submit --master local --class xxx.xxxx.xxx.xxxx.xxxxxxxxxxxxJob --conf 'spark.driver.extraJavaOptions=-Dconfig.resource=xxx.conf' /home/xxxxx/workspace/prueba/pruebas/目标/scala-2.11/MiPrueba.jar
我收到以下错误:
线程“main”中的异常 java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps;
在 pureconfig.DurationUtils$.words(DurationUtils.scala:36)
在 pureconfig.DurationUtils$.pureconfig$DurationUtils$$expandLabels(DurationUtils.scala:38)
在 pureconfig.DurationUtils$$anonfun$2.apply(DurationUtils.scala:53)
在 pureconfig.DurationUtils$$anonfun$2.apply(DurationUtils.scala:53)
在 scala.collection.immutable.List.flatMap(List.scala:338)
在 pureconfig.DurationUtils$ 处。(DurationUtils.scala:53)
在 pureconfig.DurationUtils$.(DurationUtils.scala)
在 pureconfig.DurationReaders$class.$init$(BasicReaders.scala:114)
在 pureconfig.ConfigReader$ 处。(ConfigReader.scala:121)
在 pureconfig.ConfigReader$.(ConfigReader.scala)
在 xxx.xxxx.xxx.xxxx.config.package$Config$.load(package.scala:67)
在 xxx.xxxx.xxx.xxxx.job.xxxxJob$class.main(XXXxxx.scala:23)
在xxx.xxxx.xxx.xxxx......作业$.main(Xxxxxxxxxxxxx.scala:19)
在 xxx.xxxx.xxx.xxxx..main(XXXXXXxxxxxxxx.scala)
在 sun.reflect.NativeMethodAccessorImpl.invoke0(本机方法)
在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
在 java.lang.reflect.Method.invoke(Method.java:498)
在 org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52)
在 org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:849)
在 org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:167)
在 org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:195)
在 org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:86)
在 org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:924)
在 org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:933)
在 org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
构建定义:
版本:=“0.1”
scala版本 := "2.11.11"
库依赖项:
val dependFullList = spark ++ hadoop ++ apisDownload ++ configuration
Run Code Online (Sandbox Code Playgroud)
配置:
val configuration = Seq(
"com.github.pureconfig" %% "pureconfig" % "0.9.2",
"com.typesafe" % "config" % "1.3.1",
"org.lz4" % "lz4-java" % "1.4.1"
)
Run Code Online (Sandbox Code Playgroud)
火花:
val spark = Seq(
"org.apache.spark" %% "spark-core" % Versions.spark % "provided" exclude("javax.jms", "jms"),
"org.apache.spark" %% "spark-sql" % Versions.spark % "provided",
"com.databricks" %% "spark-xml" % "0.4.1"
// https://mvnrepository.com/artifact/mrpowers/spark-daria
)
Run Code Online (Sandbox Code Playgroud)
有任何想法吗?
你正在混合 scala 版本。Spark 2.4.2 不支持 scala 2.11。切换到 Spark 2.4.0 或将库替换为 scala 2.12 版本。
https://spark.apache.org/releases/spark-release-2-4-2.html
请注意,从 2.4.1 开始,Scala 2.11 支持已弃用。从 2.4.2 开始,预构建的便利二进制文件是针对 Scala 2.12 编译的。Spark 仍然在 Maven Central 中交叉发布 2.11 和 2.12,并且可以从源代码构建 2.11。
| 归档时间: |
|
| 查看次数: |
2521 次 |
| 最近记录: |