[SPARK-12611][SQL][PYSPARK][TESTS] Fix test_infer_schema_to_local

holdenk · rxin · commit 13dab9c3862c · 2016-01-03T17:04:35.000-08:00
Previously (when the PR was first created) not specifying b= explicitly was fine (and treated as default null) - instead be explicit about b being None in the test. Author: Holden Karau <holden@us.ibm.com> Closes apache#10564 from holdenk/SPARK-12611-fix-test-infer-schema-local.
diff --git a/python/pyspark/sql/tests.py b/python/pyspark/sql/tests.py
@@ -360,7 +360,7 @@ def test_infer_schema_to_local(self):
         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())
 
