Repository: mahout Updated Branches: refs/heads/flink-binding cd4e3cec3 -> e75c5f606
MAHOUT-1811: Fix DRM norm formula closes apache/mahout#192 Project: http://git-wip-us.apache.org/repos/asf/mahout/repo Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/e75c5f60 Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/e75c5f60 Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/e75c5f60 Branch: refs/heads/flink-binding Commit: e75c5f6064b162e1f0469ea3e86997d1e37f9057 Parents: cd4e3ce Author: Andrew Palumbo <[email protected]> Authored: Tue Mar 15 14:47:27 2016 -0400 Committer: Andrew Palumbo <[email protected]> Committed: Tue Mar 15 14:48:43 2016 -0400 ---------------------------------------------------------------------- .../main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mahout/blob/e75c5f60/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala ---------------------------------------------------------------------- diff --git a/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala b/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala index 6312f47..3988d51 100644 --- a/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala +++ b/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala @@ -257,7 +257,9 @@ object FlinkEngine extends DistributedEngine { // }) val list = sumOfSquares.collect - list.head + + // check on this --why is it returning a list? + math.sqrt(list.head) } /** Broadcast support */
