mahout-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apalu...@apache.org
Subject mahout git commit: (nojira) fix tmp directory for cache. closes apache/mahout#220
Date Mon, 11 Apr 2016 01:18:06 GMT
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 <apalumbo@apache.org>
Authored: Sun Apr 10 21:11:57 2016 -0400
Committer: Andrew Palumbo <apalumbo@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)


Mime
View raw message