diff options
author | Josh Rosen <joshrosen@databricks.com> | 2015-02-17 07:48:27 -0800 |
---|---|---|
committer | Josh Rosen <joshrosen@databricks.com> | 2015-02-17 07:49:02 -0800 |
commit | ee6e3eff02e9e08b1113ba6faf3397d7e7775087 (patch) | |
tree | d5dc43f81dfa66db59436df0f1932f25d36a763a /python | |
parent | a65766bf0244a41b793b9dc5fbdd2882664ad00e (diff) | |
download | spark-ee6e3eff02e9e08b1113ba6faf3397d7e7775087.tar.gz spark-ee6e3eff02e9e08b1113ba6faf3397d7e7775087.tar.bz2 spark-ee6e3eff02e9e08b1113ba6faf3397d7e7775087.zip |
Revert "[SPARK-5363] [PySpark] check ending mark in non-block way"
This reverts commits ac6fe67e1d8bf01ee565f9cc09ad48d88a275829 and c06e42f2c1e5fcf123b466efd27ee4cb53bbed3f.
Diffstat (limited to 'python')
-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: |