diff --git a/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala b/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala index 499b756ce7fee..c0ea69a7cedba 100644 --- a/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/CoGroupedRDD.scala @@ -32,7 +32,7 @@ import org.apache.spark.serializer.Serializer /** The references to rdd and splitIndex are transient because redundant information is stored * in the CoGroupedRDD object. Because CoGroupedRDD is serialized separately from - * CoGrpupPartition, if rdd and splitIndex aren't transient, they'll be included twice in the + * CoGroupPartition, if rdd and splitIndex aren't transient, they'll be included twice in the * task closure. */ private[spark] case class NarrowCoGroupSplitDep( @transient rdd: RDD[_],