You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2016/01/04 02:04:39 UTC

spark git commit: [SPARK-12611][SQL][PYSPARK][TESTS] Fix test_infer_schema_to_local

Repository: spark
Updated Branches:
  refs/heads/master b8410ff9c -> 13dab9c38


[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 <ho...@us.ibm.com>

Closes #10564 from holdenk/SPARK-12611-fix-test-infer-schema-local.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/13dab9c3
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/13dab9c3
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/13dab9c3

Branch: refs/heads/master
Commit: 13dab9c3862cc454094cd9ba7b4504a2d095028f
Parents: b8410ff
Author: Holden Karau <ho...@us.ibm.com>
Authored: Sun Jan 3 17:04:35 2016 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Sun Jan 3 17:04:35 2016 -0800

----------------------------------------------------------------------
 python/pyspark/sql/tests.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/13dab9c3/python/pyspark/sql/tests.py
----------------------------------------------------------------------
diff --git a/python/pyspark/sql/tests.py b/python/pyspark/sql/tests.py
index 10b9917..9ada966 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())
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org