Skip to content

Commit 24c92a4

Browse files
author
Davies Liu
committed
fix style
1 parent ba54614 commit 24c92a4

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

python/pyspark/context.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -838,7 +838,8 @@ def runJob(self, rdd, partitionFunc, partitions=None, allowLocal=False):
838838
# by runJob() in order to avoid having to pass a Python lambda into
839839
# SparkContext#runJob.
840840
mappedRDD = rdd.mapPartitions(partitionFunc)
841-
port = self._jvm.PythonRDD.runJob(self._jsc.sc(), mappedRDD._jrdd, javaPartitions, allowLocal)
841+
port = self._jvm.PythonRDD.runJob(self._jsc.sc(), mappedRDD._jrdd, javaPartitions,
842+
allowLocal)
842843
return list(_load_from_socket(port, mappedRDD._jrdd_deserializer))
843844

844845
def show_profiles(self):

0 commit comments

Comments
 (0)