aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2013-04-07 20:55:42 -0400
committerMatei Zaharia <matei@eecs.berkeley.edu>2013-04-07 20:55:42 -0400
commitb5900d47b1386f5bc21df5db32b09b2d44e9dba7 (patch)
treee06246250751d615efe57d8715a7baaa7f8e82b5
parent1cb3eb9762439caea10fe817d9c69c01c3c8fb06 (diff)
downloadspark-b5900d47b1386f5bc21df5db32b09b2d44e9dba7.tar.gz
spark-b5900d47b1386f5bc21df5db32b09b2d44e9dba7.tar.bz2
spark-b5900d47b1386f5bc21df5db32b09b2d44e9dba7.zip
Fix compile warning
-rw-r--r--core/src/main/scala/spark/rdd/CheckpointRDD.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/rdd/CheckpointRDD.scala b/core/src/main/scala/spark/rdd/CheckpointRDD.scala
index 9e37bdf659..5db77eb142 100644
--- a/core/src/main/scala/spark/rdd/CheckpointRDD.scala
+++ b/core/src/main/scala/spark/rdd/CheckpointRDD.scala
@@ -122,6 +122,6 @@ private[spark] object CheckpointRDD extends Logging {
val cpRDD = new CheckpointRDD[Int](sc, path.toString)
assert(cpRDD.partitions.length == rdd.partitions.length, "Number of partitions is not the same")
assert(cpRDD.collect.toList == rdd.collect.toList, "Data of partitions not the same")
- fs.delete(path)
+ fs.delete(path, true)
}
}