diff --git a/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala b/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala index 1f4e784723..79f9c1396c 100644 --- a/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala +++ b/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala @@ -1298,19 +1298,15 @@ class SizeBasedCoalescer(val maxSize: Int) extends PartitionCoalescer with Seria val splitSize = fileSplit.getLength if (currentSum + splitSize < maxSize) { addPartition(partition, splitSize) - index += 1 - if (index == partitions.size) { - updateGroups - } } else { - if (currentGroup.partitions.size == 0) { - addPartition(partition, splitSize) - index += 1 - } else { - updateGroups + if (currentGroup.partitions.nonEmpty) { + updateGroups() } + addPartition(partition, splitSize) } + index += 1 } + updateGroups() groups.toArray } }