diff --git a/python/pyspark/sql/tests.py b/python/pyspark/sql/tests.py index 10b99175ad952729f2abb9fc34baebd0dd232d86..9ada96601a1cd283696ae6a22da14f603b66ca6b 100644 --- a/python/pyspark/sql/tests.py +++ b/python/pyspark/sql/tests.py @@ -360,7 +360,7 @@ class SQLTests(ReusedPySparkTestCase): df2 = self.sqlCtx.createDataFrame(rdd, samplingRatio=1.0) self.assertEqual(df.schema, df2.schema) - rdd = self.sc.parallelize(range(10)).map(lambda x: Row(a=x)) + rdd = self.sc.parallelize(range(10)).map(lambda x: Row(a=x, b=None)) df3 = self.sqlCtx.createDataFrame(rdd, df.schema) self.assertEqual(10, df3.count())