diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
index f83945a105efc..5ff11de71112d 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 with error code %d" %(command, pipe.returncode) )
+                raise Exception("Pipe function `%s' exited with error code %d" %(command, pipe.returncode))
             return result
         return self.mapPartitions(func)