Skip to content

Commit 50581fc

Browse files
committed
added a TODO for logging in python
1 parent 46f6c8c commit 50581fc

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

python/pyspark/rdd.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -385,6 +385,7 @@ def takeSample(self, withReplacement, num, seed=None):
385385
# See: scala/spark/RDD.scala
386386
rand = Random(seed)
387387
while len(samples) < total:
388+
#TODO add log warning when more than one iteration was run
388389
samples = self.sample(withReplacement, fraction, rand.randint(0, sys.maxint)).collect()
389390

390391
sampler = RDDSampler(withReplacement, fraction, rand.randint(0, sys.maxint))

0 commit comments

Comments
 (0)