diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
index 2b38289a1356f..a86fae6d2edb8 100644
--- a/python/pyspark/rdd.py
+++ b/python/pyspark/rdd.py
@@ -707,7 +707,7 @@ def pipe_objs(out):
             result = (x.rstrip(b'\n').decode('utf-8') for x in iter(pipe.stdout.readline, b''))
             pipe.wait()
             if pipe.returncode:
-                raise Exception("Pipe function `%s' exited"
+                raise Exception("Pipe function `%s' exited "
                                 "with error code %d" %(command, pipe.returncode))
             return result
         return self.mapPartitions(func)