Fix python style.

apache · Jan 23, 2018 · 5c3afbb · 5c3afbb
1 parent f1db144
commit 5c3afbb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/pyspark/sql/tests.py b/python/pyspark/sql/tests.py
@@ -1109,7 +1109,7 @@ def myudf(x):
     def test_nonparam_udf_with_aggregate(self):
         import pyspark.sql.functions as f
 
-        df = self.spark.createDataFrame([(1,2), (1,2)])
+        df = self.spark.createDataFrame([(1, 2), (1, 2)])
         f_udf = f.udf(lambda: "const_str")
         rows = df.distinct().withColumn("a", f_udf()).collect()
         self.assertEqual(rows, [Row(_1=1, _2=2, a=u'const_str')])