sometimes I'm getting this exception:
Traceback (most recent call last):
File "/opt/spark-1.2.0-bin-hadoop2.4/python/pyspark/daemon.py", line 162,
in manager
code = worker(sock)
File "/opt/spark-1.2.0-bin-hadoop2.4/python/pyspark/daemon.py", line 64,
in worker
outfile.flush()
IOError: [Errno 32] Broken pipeIs it a spark bug?
