【发布时间】:2017-09-18 23:29:09
【问题描述】:
我正在尝试使用 SBT 使用 spark_submit 运行示例 scala 代码。这是我的 scala 代码 -
import scala.math.random
import org.apache.spark._
/** Computes an approximation to pi */
object SparkPi {
def main(args: Array[String]) {
val conf = new SparkConf().setAppName("Spark Pi")
val spark = new SparkContext(conf)
val slices = if (args.length > 0) args(0).toInt else 2
val n = 100000 * slices
val count = spark.parallelize(1 to n, slices).map { i =>
val x = random * 2 - 1
val y = random * 2 - 1
if (x*x + y*y < 1) 1 else 0
}.reduce(_ + _)
println("Pi is roughly " + 4.0 * count / n)
spark.stop()
}
}
这是我的 sparksample.sbt 文件 -
name := "Spark Sample"
version := "1.0"
scalaVersion := "2.9.1"
libraryDependencies += "org.apache.spark" %% "spark-core" % "2.0.0"
但是当我运行 SBT 和打包命令时,我得到以下错误
[错误] (*:update) sbt.ResolveException: 未解决的依赖: org.apache.spark#spark-core_2.9.1;2.0.0:未找到
我的 scala 版本是 2.9.1,我的 spark 版本是 2.0.0。
我正在关注以下站点以使用 sbt 运行 spark_submit -
【问题讨论】:
标签: scala apache-spark sbt