Vallasc
diff --git a/‎jar/binary.jar‎
2 Bytes b/‎jar/binary.jar‎
2 Bytes
diff --git a/‎src/main/scala/SparkJob.scala‎
Lines changed: 1 addition & 1 deletion b/‎src/main/scala/SparkJob.scala‎
Lines changed: 1 addition & 1 deletion
@@ -40,7 +40,7 @@ class SparkJob(val padding: Int = 3,
         // Make RDD of matrixes
         //val matrixes = sc.parallelize(splitted._1, splitted._2 * splitted._3 * 100)
         val matrixes = sc.parallelize(splitted._1)
-        matrixes.partitionBy(new HashPartitioner(splitted._2 * splitted._3)).persist(StorageLevel.MEMORY_ONLY)
+        matrixes.partitionBy(new HashPartitioner(splitted._2 * splitted._3 * 50)).persist(StorageLevel.MEMORY_ONLY)
         val computed = compute(matrixes, pipeline)
 
         // Reassemble the matrix