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>]