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

Traceback (most recent call last):
  File "/home/jenkins/workspace/spark-master-test-sbt-hadoop-2.2/python/pyspark/streaming/tests.py", line 666, in test_count_by_value_and_window
    self._test_func(input, func, expected)
  File "/home/jenkins/workspace/spark-master-test-sbt-hadoop-2.2/python/pyspark/streaming/tests.py", line 160, in _test_func
    self.assertEqual(expected, result)
AssertionError: Lists differ: [[(0,[77 chars], 1)], [(0, 5), (1, 4), (2, 3), (3, 2), (4, 1)[247 chars] 1)]] != [[(0,[77 chars], 1)]]

First list contains 6 additional elements.
First extra element 4:
[(0, 5), (1, 4), (2, 3), (3, 2), (4, 1)]

  [[(0, 1)],
   [(0, 2), (1, 1)],
   [(0, 3), (1, 2), (2, 1)],
-  [(0, 4), (1, 3), (2, 2), (3, 1)],
?                                  ^

+  [(0, 4), (1, 3), (2, 2), (3, 1)]]
?                                  ^

-  [(0, 5), (1, 4), (2, 3), (3, 2), (4, 1)],
-  [(0, 5), (1, 5), (2, 4), (3, 3), (4, 2), (5, 1)],
-  [(0, 4), (1, 4), (2, 4), (3, 3), (4, 2), (5, 1)],
-  [(0, 3), (1, 3), (2, 3), (3, 3), (4, 2), (5, 1)],
-  [(0, 2), (1, 2), (2, 2), (3, 2), (4, 2), (5, 1)],
-  [(0, 1), (1, 1), (2, 1), (3, 1), (4, 1), (5, 1)]]

Stdout:
('timeout after', 15)