diff options
Diffstat (limited to 'python/pyspark')
| -rw-r--r-- | python/pyspark/worker.py | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 180bdbb4c2..8a93c320ec 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -121,7 +121,6 @@ def main(infile, outfile): write_int(len(_accumulatorRegistry), outfile) for (aid, accum) in _accumulatorRegistry.items(): pickleSer._write_with_length((aid, accum._value), outfile) - outfile.flush() # check end of stream if read_int(infile) == SpecialLengths.END_OF_STREAM: |