From 50581fc8b08bd5f18cdf2288772c22f2549af0a5 Mon Sep 17 00:00:00 2001 From: Doris Xin Date: Thu, 12 Jun 2014 14:36:37 -0700 Subject: [PATCH] added a TODO for logging in python --- python/pyspark/rdd.py | 1 + 1 file changed, 1 insertion(+) diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py index 22cead99973d1..38f353c1c29a6 100644 --- a/python/pyspark/rdd.py +++ b/python/pyspark/rdd.py @@ -385,6 +385,7 @@ def takeSample(self, withReplacement, num, seed=None): # See: scala/spark/RDD.scala rand = Random(seed) while len(samples) < total: + #TODO add log warning when more than one iteration was run samples = self.sample(withReplacement, fraction, rand.randint(0, sys.maxint)).collect() sampler = RDDSampler(withReplacement, fraction, rand.randint(0, sys.maxint))