Return-Path: X-Original-To: apmail-mahout-commits-archive@www.apache.org Delivered-To: apmail-mahout-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 3D89A1887A for ; Mon, 11 Apr 2016 01:18:07 +0000 (UTC) Received: (qmail 92657 invoked by uid 500); 11 Apr 2016 01:18:07 -0000 Delivered-To: apmail-mahout-commits-archive@mahout.apache.org Received: (qmail 92603 invoked by uid 500); 11 Apr 2016 01:18:07 -0000 Mailing-List: contact commits-help@mahout.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@mahout.apache.org Delivered-To: mailing list commits@mahout.apache.org Received: (qmail 92594 invoked by uid 99); 11 Apr 2016 01:18:06 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Apr 2016 01:18:06 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C9EE1DFC55; Mon, 11 Apr 2016 01:18:06 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: apalumbo@apache.org To: commits@mahout.apache.org Message-Id: <30fe299716664797b69881b4fdf16c5e@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: mahout git commit: (nojira) fix tmp directory for cache. closes apache/mahout#220 Date: Mon, 11 Apr 2016 01:18:06 +0000 (UTC) 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 Authored: Sun Apr 10 21:11:57 2016 -0400 Committer: Andrew Palumbo 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)