Re: what are the types of tasks when running ALS iterations
x, (bid, >> buf.toArray)) >> } >> }.groupByKey(new HashPartitioner(numBlocks)) //这里1.0.0 的 >> als代码有bug,那个版本用的是传入的partitioner,起不到作用,会导致data skew >> .join(userInLinks) >> .mapValues{ case (messages, inLinkBlock) => >> updateBlock(messages
what are the types of tasks when running ALS iterations
bda, alpha, YtY) } } -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/what-are-the-types-of-tasks-when-running-ALS-iterations-tp21966.html Sent from the Apache Spark User List mailing list archiv