From 24c92a41354c936a864a32c4dbae3fbfeeb95ce3 Mon Sep 17 00:00:00 2001 From: Davies Liu Date: Thu, 5 Mar 2015 23:15:43 -0800 Subject: [PATCH] fix style --- python/pyspark/context.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/python/pyspark/context.py b/python/pyspark/context.py index 50b69b6ac5459..78dccc40470e3 100644 --- a/python/pyspark/context.py +++ b/python/pyspark/context.py @@ -838,7 +838,8 @@ def runJob(self, rdd, partitionFunc, partitions=None, allowLocal=False): # by runJob() in order to avoid having to pass a Python lambda into # SparkContext#runJob. mappedRDD = rdd.mapPartitions(partitionFunc) - port = self._jvm.PythonRDD.runJob(self._jsc.sc(), mappedRDD._jrdd, javaPartitions, allowLocal) + port = self._jvm.PythonRDD.runJob(self._jsc.sc(), mappedRDD._jrdd, javaPartitions, + allowLocal) return list(_load_from_socket(port, mappedRDD._jrdd_deserializer)) def show_profiles(self):