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 4b6e777 commit a8e74bbCopy full SHA for a8e74bb
python/pyspark/rdd.py
@@ -1074,9 +1074,9 @@ def take(self, num):
1074
if len(items) == 0:
1075
numPartsToTry = partsScanned * 4
1076
else:
1077
- #the first paramter of max is >=1 whenever partsScanned >= 2
1078
- numPartsToTry = max(int(1.5 * num * partsScanned / len(items)) - partsScanned, 1)
1079
- numPartsToTry = min(numPartsToTry, partsScanned * 4)
+ # the first paramter of max is >=1 whenever partsScanned >= 2
+ numPartsToTry = int(1.5 * num * partsScanned / len(items)) - partsScanned
+ numPartsToTry = min(max(numPartsToTry, 1), partsScanned * 4)
1080
1081
left = num - len(items)
1082
0 commit comments