From a8e74bb0015cde80877aa7ce839f1bb4446bce80 Mon Sep 17 00:00:00 2001 From: yingjieMiao Date: Thu, 9 Oct 2014 12:08:39 -0700 Subject: [PATCH] python style fix --- python/pyspark/rdd.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 5bc87a76e4653..3bee3054d60da 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -1074,9 +1074,9 @@ def take(self, num): if len(items) == 0: numPartsToTry = partsScanned * 4 else: - #the first paramter of max is >=1 whenever partsScanned >= 2 - numPartsToTry = max(int(1.5 * num * partsScanned / len(items)) - partsScanned, 1) - 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) left = num - len(items)