You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by ap...@apache.org on 2016/04/11 03:18:06 UTC
mahout git commit: (nojira) fix tmp directory for cache. closes
apache/mahout#220
Repository: mahout
Updated Branches:
refs/heads/flink-binding 6fc010082 -> 6667bb0ad
(nojira) fix tmp directory for cache. closes apache/mahout#220
Project: http://git-wip-us.apache.org/repos/asf/mahout/repo
Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/6667bb0a
Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/6667bb0a
Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/6667bb0a
Branch: refs/heads/flink-binding
Commit: 6667bb0adf206ef5cc86520c8e211b8553ed98b3
Parents: 6fc0100
Author: Andrew Palumbo <ap...@apache.org>
Authored: Sun Apr 10 21:11:57 2016 -0400
Committer: Andrew Palumbo <ap...@apache.org>
Committed: Sun Apr 10 21:17:44 2016 -0400
----------------------------------------------------------------------
.../apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mahout/blob/6667bb0a/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
----------------------------------------------------------------------
diff --git a/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala b/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
index 794c721..1cba326 100644
--- a/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
+++ b/flink/src/main/scala/org/apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala
@@ -67,9 +67,9 @@ class CheckpointedFlinkDrm[K: ClassTag:TypeInformation](val ds: DrmDataSet[K],
val conf = GlobalConfiguration.getConfiguration
if (!(conf == null )) {
- persistanceRootDir = conf.getString("taskmanager.tmp.dirs", "/tmp/")
+ persistanceRootDir = conf.getString("taskmanager.tmp.dirs", "/tmp")
} else {
- persistanceRootDir = "/tmp/"
+ persistanceRootDir = "/tmp"
}
@@ -98,7 +98,7 @@ class CheckpointedFlinkDrm[K: ClassTag:TypeInformation](val ds: DrmDataSet[K],
* the dataset to the filesystem and read it back when cache is called */
def cache() = {
if (!isCached) {
- cacheFileName = persistanceRootDir + System.nanoTime().toString
+ cacheFileName = persistanceRootDir + "/" + System.nanoTime().toString
parallelismDeg = ds.getParallelism
isCached = true
persist(ds, cacheFileName)