Description
When Initializing factors in ALS, we should use mapPartitions instead of current map, so we can preserve existing partition of the RDD of InBlock. The RDD of InBlock is already partitioned by src block id. We don't change the partition when initializing factors.
Attachments
Issue Links
- links to