diff --git a/python/pyspark/streaming/tests.py b/python/pyspark/streaming/tests.py
index c136bf18b217e..12293a03407d8 100644
--- a/python/pyspark/streaming/tests.py
+++ b/python/pyspark/streaming/tests.py
@@ -423,7 +423,7 @@ def func(dstream):
                 .reduceByKeyAndWindow(operator.add, None, 5, 1)\
                 .filter(lambda kv: kv[1] > 0).count()
 
-        expected = [[2], [4], [6], [6], [6], [6]]
+        expected = [[1], [2], [3], [4], [5], [6]]
         self._test_func(input, func, expected)