Lists differ: [[('k', [0])], [('k', [0, 1])], [('k', [0, 1, 2])], [([41 chars]4])]] != [[('k', [0])]] First list contains 4 additional elements. First extra element 1: [('k', [0, 1])] - [[('k', [0])], ? ^ + [[('k', [0])]] ? ^ - [('k', [0, 1])], - [('k', [0, 1, 2])], - [('k', [0, 1, 2, 3])], - [('k', [0, 1, 2, 3, 4])]]

Traceback (most recent call last):
  File "/home/jenkins/workspace/spark-master-test-sbt-hadoop-2.3/python/pyspark/streaming/tests.py", line 405, in test_update_state_by_key
    self._test_func(input, func, expected)
  File "/home/jenkins/workspace/spark-master-test-sbt-hadoop-2.3/python/pyspark/streaming/tests.py", line 159, in _test_func
    self.assertEqual(expected, result)
AssertionError: Lists differ: [[('k', [0])], [('k', [0, 1])], [('k', [0, 1, 2])], [([41 chars]4])]] != [[('k', [0])]]

First list contains 4 additional elements.
First extra element 1:
[('k', [0, 1])]

- [[('k', [0])],
?              ^

+ [[('k', [0])]]
?              ^

-  [('k', [0, 1])],
-  [('k', [0, 1, 2])],
-  [('k', [0, 1, 2, 3])],
-  [('k', [0, 1, 2, 3, 4])]]

Stdout:
('timeout after', 10)