File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
core/src/main/scala/org/apache/spark/rdd Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1211,9 +1211,9 @@ abstract class RDD[T: ClassTag](
12111211 // greater than totalParts because we actually cap it at totalParts in runJob.
12121212 var numPartsToTry = 1
12131213 if (partsScanned > 0 ) {
1214- // If we didn't find any rows after the previous iteration, quadruple and retry. Otherwise,
1215- // interpolate the number of partitions we need to try, but overestimate it by 50%.
1216- // We also cap the estimation in the end.
1214+ // If we didn't find any rows after the previous iteration, quadruple and retry.
1215+ // Otherwise, interpolate the number of partitions we need to try, but overestimate
1216+ // it by 50%. We also cap the estimation in the end.
12171217 if (buf.size == 0 ) {
12181218 numPartsToTry = partsScanned * 4
12191219 } else {
You can’t perform that action at this time.
0 commit comments