Skip to content

Commit 628f33c

Browse files
JerryLeadJerryLead
authored andcommitted
set PartitionsRDD to be transient in EdgeRDDImpl and VertexRDDImpl
1 parent c0169da commit 628f33c

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

graphx/src/main/scala/org/apache/spark/graphx/impl/EdgeRDDImpl.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ import org.apache.spark.storage.StorageLevel
2626
import org.apache.spark.graphx._
2727

2828
class EdgeRDDImpl[ED: ClassTag, VD: ClassTag] private[graphx] (
29-
override val partitionsRDD: RDD[(PartitionID, EdgePartition[ED, VD])],
29+
@transient override val partitionsRDD: RDD[(PartitionID, EdgePartition[ED, VD])],
3030
val targetStorageLevel: StorageLevel = StorageLevel.MEMORY_ONLY)
3131
extends EdgeRDD[ED](partitionsRDD.context, List(new OneToOneDependency(partitionsRDD))) {
3232

graphx/src/main/scala/org/apache/spark/graphx/impl/VertexRDDImpl.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ import org.apache.spark.storage.StorageLevel
2727
import org.apache.spark.graphx._
2828

2929
class VertexRDDImpl[VD] private[graphx] (
30-
val partitionsRDD: RDD[ShippableVertexPartition[VD]],
30+
@transient val partitionsRDD: RDD[ShippableVertexPartition[VD]],
3131
val targetStorageLevel: StorageLevel = StorageLevel.MEMORY_ONLY)
3232
(implicit override protected val vdTag: ClassTag[VD])
3333
extends VertexRDD[VD](partitionsRDD.context, List(new OneToOneDependency(partitionsRDD))) {

0 commit comments

Comments
 (0)