diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
index a86fae6d2edb8..da9d11f689aef 100644
--- a/python/pyspark/rdd.py
+++ b/python/pyspark/rdd.py
@@ -708,7 +708,7 @@ def pipe_objs(out):
             pipe.wait()
             if pipe.returncode:
                 raise Exception("Pipe function `%s' exited "
-                                "with error code %d" %(command, pipe.returncode))
+                                "with error code %d" % (command, pipe.returncode))
             return result
         return self.mapPartitions(func)