We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a8e74bb commit d758218Copy full SHA for d758218
core/src/main/scala/org/apache/spark/rdd/AsyncRDDActions.scala
@@ -85,7 +85,8 @@ class AsyncRDDActions[T: ClassTag](self: RDD[T]) extends Serializable with Loggi
85
numPartsToTry = partsScanned * 4
86
} else {
87
// the left side of max is >=1 whenever partsScanned >= 2
88
- numPartsToTry = Math.max((1.5 * num * partsScanned / results.size).toInt - partsScanned, 1)
+ numPartsToTry = Math.max(1,
89
+ (1.5 * num * partsScanned / results.size).toInt - partsScanned)
90
numPartsToTry = Math.min(numPartsToTry, partsScanned * 4)
91
}
92
0 commit comments