Skip to content

Commit 35b8e3a

Browse files
committed
Another fix for test ordering
1 parent bef3afb commit 35b8e3a

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

python/pyspark/context.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -318,9 +318,9 @@ def sequenceFile(self, name, key_class="org.apache.hadoop.io.Text", value_class=
318318
[(1, None), (1, None), (2, None), (2, None), (2, None), (3, None)]
319319
>>> sorted(sc.sequenceFile(tempdir + "/sftestdata/sfmap/").collect())
320320
[(1, {2.0: u'aa'}), (1, {3.0: u'bb'}), (2, {1.0: u'aa'}), (2, {1.0: u'cc'}), (2, {3.0: u'bb'}), (3, {2.0: u'dd'})]
321-
>>> r = sc.sequenceFile(tempdir + "/sftestdata/sfclass").first()
322-
>>> [r[0], sorted([(k, v) for k, v in r[1].iteritems()])]
323-
[u'1', [(u'__class__', u'org.apache.spark.api.python.TestWritable'), (u'double', 54.0), (u'int', 123), (u'str', u'test1')]]
321+
>>> r = sorted(sc.sequenceFile(tempdir + "/sftestdata/sfclass").collect())[0]
322+
>>> r == (u'1', {u'__class__': u'org.apache.spark.api.python.TestWritable', u'double': 54.0, u'int': 123, u'str': u'test1'})
323+
True
324324
"""
325325
minSplits = minSplits or min(self.defaultParallelism, 2)
326326
jrdd = self._jvm.PythonRDD.sequenceFile(self._jsc, name, key_class, value_class, key_wrapper, value_wrapper,

0 commit comments

Comments
 (0)