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 pipe

Is it a spark bug?

Reply via email to