Merge pull request #523 from mpjlu/fixALSRandom

ALS prepare data to support scala 2.10
Intel-bigdata · Nov 6, 2017 · 133dc48 · 133dc48
2 parents dc77558 + 2bfa491
commit 133dc48
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/sparkbench/ml/src/main/scala/com/intel/sparkbench/ml/RatingDataGenerator.scala b/sparkbench/ml/src/main/scala/com/intel/sparkbench/ml/RatingDataGenerator.scala
@@ -27,8 +27,6 @@ import org.apache.spark.mllib.random._
 import org.apache.spark.rdd.{PairRDDFunctions, RDD}
 import org.apache.spark.mllib.linalg.{Vectors, Vector}
 
-import scala.util.Random
-
 object RatingDataGenerator {
 
   def main(args: Array[String]): Unit = {
@@ -64,7 +62,7 @@ object RatingDataGenerator {
     }
 
     val rawData: RDD[Vector] = RandomRDDs.normalVectorRDD(sc, numUsers, numProducts, numPartitions)
-    val rng = new Random()
+    val rng = new java.util.Random()
     val data = rawData.map{v =>
       val a = Array.fill[Double](v.size)(0.0)
       v.foreachActive{(i,vi) =>