File tree Expand file tree Collapse file tree 3 files changed +3
-11
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 3 files changed +3
-11
lines changed Original file line number Diff line number Diff line change @@ -98,13 +98,6 @@ private[spark] class ContextCleaner(sc: SparkContext) extends Logging {
98
98
listeners += listener
99
99
}
100
100
101
- /** Unpersists RDD and remove all blocks for it from memory and disk. */
102
- def unpersistRDD (rddId : Int , blocking : Boolean ) {
103
- logDebug(" Unpersisted RDD " + rddId)
104
- sc.env.blockManager.master.removeRdd(rddId, blocking)
105
- sc.persistentRdds.remove(rddId)
106
- }
107
-
108
101
/** Register an object for cleanup. */
109
102
private def registerForCleanup (objectForCleanup : AnyRef , task : CleanupTask ) {
110
103
referenceBuffer += new WeakReferenceWithCleanupTask (objectForCleanup, task)
@@ -136,7 +129,7 @@ private[spark] class ContextCleaner(sc: SparkContext) extends Logging {
136
129
private def doCleanupRDD (rddId : Int ) {
137
130
try {
138
131
logDebug(" Cleaning RDD " + rddId)
139
- unpersistRDD(rddId, false )
132
+ sc. unpersistRDD(rddId, false )
140
133
listeners.foreach(_.rddCleaned(rddId))
141
134
logInfo(" Cleaned RDD " + rddId)
142
135
} catch {
Original file line number Diff line number Diff line change @@ -756,8 +756,7 @@ class SparkContext(
756
756
/**
757
757
* Unpersist an RDD from memory and/or disk storage
758
758
*/
759
- private [spark] def unpersistRDD (rdd : RDD [_], blocking : Boolean = true ) {
760
- val rddId = rdd.id
759
+ private [spark] def unpersistRDD (rddId : Int , blocking : Boolean = true ) {
761
760
env.blockManager.master.removeRdd(rddId, blocking)
762
761
persistentRdds.remove(rddId)
763
762
listenerBus.post(SparkListenerUnpersistRDD (rddId))
Original file line number Diff line number Diff line change @@ -158,7 +158,7 @@ abstract class RDD[T: ClassTag](
158
158
*/
159
159
def unpersist (blocking : Boolean = true ): RDD [T ] = {
160
160
logInfo(" Removing RDD " + id + " from persistence list" )
161
- sc.unpersistRDD(this , blocking)
161
+ sc.unpersistRDD(this .id , blocking)
162
162
storageLevel = StorageLevel .NONE
163
163
this
164
164
}
You can’t perform that action at this time.
0 commit comments