scala - java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps; 斯卡拉
问题描述
嗨,我正在使用 scala 研究火花。我运行代码以找出文件中有多少单词以及每个单词的频率。但是当我运行代码时会发生此错误。
java.lang.NoSuchMethodError: scala.Predef$.refArrayOps([Ljava/lang/Object;)Lscala/collection/mutable/ArrayOps;
at example.word_count$$anonfun$2.apply(word_count.scala:19)
at example.word_count$$anonfun$2.apply(word_count.scala:19)
at scala.collection.Iterator$$anon$11.nextCur(Iterator.scala:484)
at scala.collection.Iterator$$anon$11.hasNext(Iterator.scala:490)
at scala.collection.Iterator$$anon$10.hasNext(Iterator.scala:458)
at org.apache.spark.util.collection.ExternalSorter.insertAll(ExternalSorter.scala:192)
at org.apache.spark.shuffle.sort.SortShuffleWriter.write(SortShuffleWriter.scala:62)
at org.apache.spark.shuffle.ShuffleWriteProcessor.write(ShuffleWriteProcessor.scala:59)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:99)
at org.apache.spark.scheduler.ShuffleMapTask.runTask(ShuffleMapTask.scala:52)
at org.apache.spark.scheduler.Task.run(Task.scala:131)
at org.apache.spark.executor.Executor$TaskRunner.$anonfun$run$3(Executor.scala:497)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1439)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:500)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
这是 build.sbt
val sparkVersion = "3.1.2"
ThisBuild / scalaVersion := "2.11.12"
ThisBuild / version := "0.1.0-SNAPSHOT"
ThisBuild / organization := "com.example"
ThisBuild / organizationName := "example"
lazy val root = (project in file("."))
.settings(
name := "word_count",
)
libraryDependencies ++= Seq(
"org.apache.spark" % "spark-core_2.11" % "2.4.5",
"org.apache.spark" % "spark-mllib_2.11" % "2.4.0",
"org.apache.spark" % "spark-streaming_2.11" % "2.1.1",
"org.apache.spark" % "spark-sql_2.11" % "2.1.0",
"org.scalactic" %% "scalactic" % "3.2.10",
"org.scalatest" %% "scalatest" % "3.2.10" % "test"
)
assemblyMergeStrategy in assembly := {
case PathList("META-INF", xs @ _*) => MergeStrategy.discard
case x => MergeStrategy.first
}
如何纠正这个问题,任何帮助表示赞赏
解决方案
推荐阅读
- chart.js - 如何在charjs中的y轴上显示条形图
- python - 我只想在kivy中依次单击两个按钮时打印文本
- pagination - 为什么分页小部件不包括我的查询字符串参数?
- templates - TYPO3 10 : 如何在我的扩展中显示图像的元数据类别?
- python - 如何根据另一个数据框中的过滤值聚合一个数据框中的统计信息?
- angular - 角度材质对话框未正确呈现
- javascript - 我收到以下错误。未捕获的类型错误:无法读取未定义的属性“文件”
- mongoose - 猫鼬如何在保存时返回特定字段
- android-recyclerview - android RecyclerView 在键盘打开之前不会呈现
- ssas - 将 SSAS 中的小数分隔符从点更改为逗号