diff --git a/pysparkling/tests/test_streaming_files.py b/pysparkling/tests/test_streaming_files.py
index d7136b231..1bd961a63 100644
--- a/pysparkling/tests/test_streaming_files.py
+++ b/pysparkling/tests/test_streaming_files.py
@@ -18,7 +18,7 @@ def test_connect(self):
 
         ssc.start()
         ssc.awaitTermination(timeout=0.3)
-        self.assertEqual(sum(result), 22)
+        self.assertEqual(sum(result), 43)
 
     def test_save(self):
         sc = pysparkling.Context()
@@ -71,4 +71,4 @@ def test_read_chunks(self):
 
         ssc.start()
         ssc.awaitTermination(timeout=0.3)
-        self.assertEqual(sum(result), 28)
+        self.assertEqual(sum(result), 52)