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 f552d49 commit 5745d85Copy full SHA for 5745d85
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 with error code %d" %(command, pipe.returncode) )
+ raise Exception("Pipe function `%s' exited with error code %d" %(command, pipe.returncode))
711
return result
712
return self.mapPartitions(func)
713
0 commit comments