Repository: mahout Updated Branches: refs/heads/flink-binding eda8a38e4 -> fd0112dcf
NoJira: Fix the compile issue from previous commit Project: http://git-wip-us.apache.org/repos/asf/mahout/repo Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/fd0112dc Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/fd0112dc Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/fd0112dc Branch: refs/heads/flink-binding Commit: fd0112dcf3ac8219b169aa03bed1de3e3333c1a8 Parents: eda8a38 Author: smarthi <[email protected]> Authored: Tue Mar 15 16:26:24 2016 -0400 Committer: smarthi <[email protected]> Committed: Tue Mar 15 16:26:24 2016 -0400 ---------------------------------------------------------------------- .../main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mahout/blob/fd0112dc/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 0ac6011..031b9b0 100644 --- a/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala +++ b/flink/src/main/scala/org/apache/mahout/flinkbindings/FlinkEngine.scala @@ -331,7 +331,7 @@ object FlinkEngine extends DistributedEngine { } val result = dc.env.fromCollection(nonParallelResult) - new CheckpointedFlinkDrm[Long](ds = result, nrow, ncol, cacheHint = CacheHint.NONE) + new CheckpointedFlinkDrm[Long](ds = result, _nrow = nrow, _ncol = ncol, cacheHint = CacheHint.NONE) } /**
