[MAHOUT-1971] Aggregate Transpose Bug

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.13.1
• Assignee: Trevor Grant
• Reporter: Trevor Grant
• Created: 22/Apr/17 18:37
• Updated: 22/Apr/17 19:30
• Resolved: 22/Apr/17 19:00

Description

In the At operation of Flink and spark there is a line that looks like:

case (row, blockRow) => colV(row) = blockA(blockRow, blockCol)

that ought to be

case (row, blockRow) => colV(row) += blockA(blockRow, blockCol)

Since it isnt'- the 'aggregate transpose' does not operate as expected.

This needs to be updated in the Spark and Flink bindings (same one char fix).

Test coverage should be updated to catch this.

Issue Links

• links to: GitHub Pull Request #307