aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/rdd.py
diff options
context:
space:
mode:
authorJey Kottalam <jey@cs.berkeley.edu>2013-04-02 11:58:40 -0700
committerJey Kottalam <jey@cs.berkeley.edu>2013-04-02 11:59:20 -0700
commit9a731f5a6dd56f5bc9eda3bb3177f7bbbb251c31 (patch)
treeb30e69e40ee79ce56b4de83ab770ea35115b515b /python/pyspark/rdd.py
parent20604001e280a445d7c25bac6eb31b1f0512c20f (diff)
downloadspark-9a731f5a6dd56f5bc9eda3bb3177f7bbbb251c31.tar.gz
spark-9a731f5a6dd56f5bc9eda3bb3177f7bbbb251c31.tar.bz2
spark-9a731f5a6dd56f5bc9eda3bb3177f7bbbb251c31.zip
Fix Python saveAsTextFile doctest to not expect order to be preserved
Diffstat (limited to 'python/pyspark/rdd.py')
-rw-r--r--python/pyspark/rdd.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
index 172ed85fab..a9fec17a9d 100644
--- a/python/pyspark/rdd.py
+++ b/python/pyspark/rdd.py
@@ -399,7 +399,7 @@ class RDD(object):
>>> sc.parallelize(range(10)).saveAsTextFile(tempFile.name)
>>> from fileinput import input
>>> from glob import glob
- >>> ''.join(input(glob(tempFile.name + "/part-0000*")))
+ >>> ''.join(sorted(input(glob(tempFile.name + "/part-0000*"))))
'0\\n1\\n2\\n3\\n4\\n5\\n6\\n7\\n8\\n9\\n'
"""
def func(split, iterator):