fix

Author: suyanNone

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

@@ -75,10 +75,6 @@ class EdgeRDDImpl[ED: ClassTag, VD: ClassTag] private[graphx] (
     partitionsRDD.checkpoint()
   }
 
-  override def isCheckpointed: Boolean = {
-    firstParent[(PartitionID, EdgePartition[ED, VD])].isCheckpointed
-  }
-
   override def getCheckpointFile: Option[String] = {
     partitionsRDD.getCheckpointFile
   }

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

@@ -68,7 +68,8 @@ class GraphImpl[VD: ClassTag, ED: ClassTag] protected (
   }
 
   override def isCheckpointed: Boolean = {
-    vertices.isCheckpointed && replicatedVertexView.edges.isCheckpointed
+    vertices.partitionsRDD.isCheckpointed &&
+      replicatedVertexView.edges.partitionsRDD.isCheckpointed
   }
 
   override def getCheckpointFiles: Seq[String] = {

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

@@ -75,10 +75,6 @@ class VertexRDDImpl[VD] private[graphx] (
     partitionsRDD.checkpoint()
   }
 
-  override def isCheckpointed: Boolean = {
-    firstParent[ShippableVertexPartition[VD]].isCheckpointed
-  }
-
   override def getCheckpointFile: Option[String] = {
     partitionsRDD.getCheckpointFile
   }