File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
core/src/main/scala/org/apache/spark/rdd Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -84,7 +84,8 @@ class AsyncRDDActions[T: ClassTag](self: RDD[T]) extends Serializable with Loggi
8484 if (results.size == 0 ) {
8585 numPartsToTry = totalParts - 1
8686 } else {
87- numPartsToTry = ((1.5 * num * partsScanned / results.size).toInt - partsScanned) max 1 // the left side of max is >=1 whenever partsScanned >= 2
87+ // the left side of max is >=1 whenever partsScanned >= 2
88+ numPartsToTry = ((1.5 * num * partsScanned / results.size).toInt - partsScanned) max 1
8889 }
8990 }
9091
Original file line number Diff line number Diff line change @@ -1084,7 +1084,8 @@ abstract class RDD[T: ClassTag](
10841084 if (buf.size == 0 ) {
10851085 numPartsToTry = partsScanned * 4
10861086 } else {
1087- numPartsToTry = ((1.5 * num * partsScanned / buf.size).toInt - partsScanned) max 1 // the left side of max is >=1 whenever partsScanned >= 2
1087+ // the left side of max is >=1 whenever partsScanned >= 2
1088+ numPartsToTry = ((1.5 * num * partsScanned / buf.size).toInt - partsScanned) max 1
10881089 }
10891090 }
10901091
You can’t perform that action at this time.
0 commit comments