Perfect. Thank you.

Unfortunately, now I receive this exception:

java.io.IOException: wrong value class: org.apache.mahout.math.hadoop.DistributedRowMatrix$MatrixEntryWritable is not class org.apache.mahout.math.VectorWritable

My Mapper's value output and Reducer's input is a DRM.MatrixEntryWritable, and is specified as such in the Conf object. The Reducer's output is a VectorWritable. The stack trace doesn't mention any code of mine, so I'm not sure how to approach this.

The basic problem is that something has produced data that uses a long as an
ID and your mapper is expecting an int.  Have you posted your code as a
patch on the jira or a git link?

I attached a patch to my project's ticket on jira (363).

Thanks again!

Regards,
Shannon

Reply via email to