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 index 886aa6c31..84ec2df9b 100644 --- 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) =>