1.2
I run() you have
usersOut.setName("usersOut").persist(StorageLevel.MEMORY_AND_DISK)
productsOut.setName("productsOut").persist(StorageLevel.MEMORY_AND_DISK)
On Wed, Jan 7, 2015, 02:11 Xiangrui Meng <men...@gmail.com> wrote:
> Which Spark version are you using? We made this configurable in 1.1:
>
>
> https://github.com/apache/spark/blob/master/mllib/src/main/scala/org/apache/spark/mllib/recommendation/ALS.scala#L202
>
> -Xiangrui
>
> On Tue, Jan 6, 2015 at 12:57 PM, Fernando O. <fot...@gmail.com> wrote:
>
>> Hi,
>> I was doing a tests with ALS and I noticed that if I persist the inner
>> RDDs from a MatrixFactorizationModel the RDD is not replicated, it seems
>> like the storagelevel is hardcoded to MEMORY_AND_DISK, do you think it
>> makes sense to make that configurable?
>> [image: Inline image 1]
>>
>
>
