File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
core/src/test/scala/org/apache/spark Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -54,7 +54,7 @@ trait RDDCheckpointTester { self: SparkFunSuite =>
5454 // Generate the final RDD using given RDD operation
5555 val baseRDD = generateFatRDD()
5656 val operatedRDD = op(baseRDD)
57- val parentRDD = operatedRDD.dependencies.headOption.orNull
57+ val parentDependency = operatedRDD.dependencies.headOption.orNull
5858 val rddType = operatedRDD.getClass.getSimpleName
5959 val numPartitions = operatedRDD.partitions.length
6060
@@ -82,7 +82,7 @@ trait RDDCheckpointTester { self: SparkFunSuite =>
8282 }
8383
8484 // Test whether dependencies have been changed from its earlier parent RDD
85- assert(operatedRDD.dependencies.head != parentRDD )
85+ assert(operatedRDD.dependencies.head != parentDependency )
8686
8787 // Test whether the partitions have been changed from its earlier partitions
8888 assert(operatedRDD.partitions.toList != partitionsBeforeCheckpoint.toList)
You can’t perform that action at this time.
0 commit comments