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