aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/sql/tests.py
diff options
context:
space:
mode:
authorHolden Karau <holden@us.ibm.com>2016-01-03 17:04:35 -0800
committerReynold Xin <rxin@databricks.com>2016-01-03 17:04:35 -0800
commit13dab9c3862cc454094cd9ba7b4504a2d095028f (patch)
tree76f1319439f7ea5fc63ada400f2897725a224739 /python/pyspark/sql/tests.py
parentb8410ff9ce8cef7159a7364272e4c4234c5b474f (diff)
downloadspark-13dab9c3862cc454094cd9ba7b4504a2d095028f.tar.gz
spark-13dab9c3862cc454094cd9ba7b4504a2d095028f.tar.bz2
spark-13dab9c3862cc454094cd9ba7b4504a2d095028f.zip
[SPARK-12611][SQL][PYSPARK][TESTS] Fix test_infer_schema_to_local
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 #10564 from holdenk/SPARK-12611-fix-test-infer-schema-local.
Diffstat (limited to 'python/pyspark/sql/tests.py')
-rw-r--r--python/pyspark/sql/tests.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/sql/tests.py b/python/pyspark/sql/tests.py
index 10b99175ad..9ada96601a 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())