We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 45f4977 commit 0974f98Copy full SHA for 0974f98
python/pyspark/rdd.py
@@ -707,7 +707,7 @@ def pipe_objs(out):
707
result = (x.rstrip(b'\n').decode('utf-8') for x in iter(pipe.stdout.readline, b''))
708
pipe.wait()
709
if pipe.returncode:
710
- raise Exception("Pipe function `%s' exited"
+ raise Exception("Pipe function `%s' exited "
711
"with error code %d" %(command, pipe.returncode))
712
return result
713
return self.mapPartitions(func)
0 commit comments