diff options
author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-04-07 20:55:42 -0400 |
---|---|---|
committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-04-07 20:55:42 -0400 |
commit | b5900d47b1386f5bc21df5db32b09b2d44e9dba7 (patch) | |
tree | e06246250751d615efe57d8715a7baaa7f8e82b5 | |
parent | 1cb3eb9762439caea10fe817d9c69c01c3c8fb06 (diff) | |
download | spark-b5900d47b1386f5bc21df5db32b09b2d44e9dba7.tar.gz spark-b5900d47b1386f5bc21df5db32b09b2d44e9dba7.tar.bz2 spark-b5900d47b1386f5bc21df5db32b09b2d44e9dba7.zip |
Fix compile warning
-rw-r--r-- | core/src/main/scala/spark/rdd/CheckpointRDD.scala | 2 |
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) } } |