scala – SparkPi运行速度超过1个切片

相对较新的spark并尝试在独立的12核三机群上运行SparkPi示例.我无法理解的是,与使用12个切片相比,使用单个切片运行此示例可以提供更好的性能.我使用并行化功能的情况也是如此.通过添加每个切片,时间几乎是线性缩放.如果我做错了,请告诉我.代码段如下：

val spark = new SparkContext("spark://telecom:7077","SparkPi",System.getenv("SPARK_HOME"),List("target/scala-2.10/sparkpii_2.10-1.0.jar"))
val slices = 1
val n = 10000000 * 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()

更新：问题在于随机函数,因为它是一个同步方法,它无法扩展到多个核心.