You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by sm...@apache.org on 2016/03/15 21:26:30 UTC
mahout git commit: NoJira: Fix the compile issue from previous commit
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 <sm...@apache.org>
Authored: Tue Mar 15 16:26:24 2016 -0400
Committer: smarthi <sm...@apache.org>
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)
}
/**