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 5745d85 commit 45f4977Copy full SHA for 45f4977
python/pyspark/rdd.py
@@ -707,7 +707,8 @@ 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 with error code %d" %(command, pipe.returncode))
+ raise Exception("Pipe function `%s' exited"
711
+ "with error code %d" %(command, pipe.returncode))
712
return result
713
return self.mapPartitions(func)
714
0 commit comments