(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/master Commit: 6667bb0adf206ef5cc86520c8e211b8553ed98b3 Parents: 6fc0100 Author: Andrew Palumbo <[email protected]> Authored: Sun Apr 10 21:11:57 2016 -0400 Committer: Andrew Palumbo <[email protected]> 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)
