fix

svenkreiss · May 11, 2019 · 5ffcf9d · 5ffcf9d
1 parent b932afa
commit 5ffcf9d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)