Lists differ: [<pys[46 chars]fed80153c90>, <pyspark.streaming.kafka.OffsetR[26 chars]3d0>] != [<pys[46 chars]fed800e6e50>] First list contains 1 additional elements. First extra element 1: OffsetRange(topic: topic-5566, partition: 0, range: [6 -> 6] - [<pyspark.streaming.kafka.OffsetRange object at 0x7fed80153c90>, ? ^ --- ^ + [<pyspark.streaming.kafka.OffsetRange object at 0x7fed800e6e50>] ? ^^^^ ^ - <pyspark.streaming.kafka.OffsetRange object at 0x7fed800f43d0>]


Traceback (most recent call last):
  File "/home/jenkins/workspace/Spark-1.6-SBT/AMPLAB_JENKINS_BUILD_PROFILE/hadoop1.0/label/spark-test/python/pyspark/streaming/tests.py", line 1112, in test_kafka_direct_stream_foreach_get_offsetRanges
    self.assertEqual(offsetRanges, [OffsetRange(topic, 0, long(0), long(6))])
AssertionError: Lists differ: [<pys[46 chars]fed80153c90>, <pyspark.streaming.kafka.OffsetR[26 chars]3d0>] != [<pys[46 chars]fed800e6e50>]

First list contains 1 additional elements.
First extra element 1:
OffsetRange(topic: topic-5566, partition: 0, range: [6 -> 6]

- [<pyspark.streaming.kafka.OffsetRange object at 0x7fed80153c90>,
?                                                         ^ ---  ^

+ [<pyspark.streaming.kafka.OffsetRange object at 0x7fed800e6e50>]
?                                                         ^^^^   ^

-  <pyspark.streaming.kafka.OffsetRange object at 0x7fed800f43d0>]