[09/50] [abbrv] mahout git commit: add unchace

[smarthi]

add unchace


Project: http://git-wip-us.apache.org/repos/asf/mahout/repo
Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/ad4c32ce
Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/ad4c32ce
Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/ad4c32ce

Branch: refs/heads/master
Commit: ad4c32ce871df686267df1f1dbff76a883b8d3fc
Parents: 9c5ee59
Author: Andrew Palumbo <apalu...@apache.org>
Authored: Fri Mar 25 18:31:51 2016 -0400
Committer: Andrew Palumbo <apalu...@apache.org>
Committed: Fri Mar 25 18:31:51 2016 -0400

----------------------------------------------------------------------
 .../apache/mahout/flinkbindings/drm/CheckpointedFlinkDrm.scala | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mahout/blob/ad4c32ce/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 65acbd6..5246938 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
@@ -27,6 +27,7 @@ import org.apache.flink.core.fs.Path
 import org.apache.flink.api.scala.hadoop.mapred.HadoopOutputFormat
 import org.apache.hadoop.io.{IntWritable, LongWritable, Text, Writable}
 import org.apache.hadoop.mapred.{FileOutputFormat, JobConf, 
SequenceFileOutputFormat}
+import org.apache.mahout.flinkbindings.io.Hadoop2HDFSUtil
 import org.apache.mahout.flinkbindings.{DrmDataSet, _}
 import org.apache.mahout.math._
 import org.apache.mahout.math.drm.CacheHint._
@@ -92,7 +93,10 @@ class CheckpointedFlinkDrm[K: ClassTag:TypeInformation](val 
ds: DrmDataSet[K],
   }
 
   def uncache() = {
-    // TODO
+    if (isCached) {
+      Hadoop2HDFSUtil.delete(cacheFileName)
+      isCached = false
+    }
     this
   }