Repository: spark
Updated Branches:
  refs/heads/branch-2.3 7de4bef9e -> 867d948a6


[SPARK-24262][PYTHON] Fix typo in UDF type match error message

## What changes were proposed in this pull request?

Updates `functon` to `function`. This was called out in holdenk's PyCon 2018 
conference talk. Didn't see any existing PR's for this.

holdenk happy to fix the Pandas.Series bug too but will need a bit more 
guidance.

Author: Kelley Robinson <krobin...@twilio.com>

Closes #21304 from robinske/master.

(cherry picked from commit 0d210ec8b610e4b0570ce730f3987dc86787c663)
Signed-off-by: Holden Karau <hol...@pigscanfly.ca>


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

Branch: refs/heads/branch-2.3
Commit: 867d948a666605cc53fc200df753abf93cb814fb
Parents: 7de4bef
Author: Kelley Robinson <krobin...@twilio.com>
Authored: Sun May 13 13:19:03 2018 -0700
Committer: Holden Karau <hol...@pigscanfly.ca>
Committed: Sun May 13 13:20:30 2018 -0700

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


http://git-wip-us.apache.org/repos/asf/spark/blob/867d948a/python/pyspark/worker.py
----------------------------------------------------------------------
diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py
index dec0642..44e9106 100644
--- a/python/pyspark/worker.py
+++ b/python/pyspark/worker.py
@@ -81,7 +81,7 @@ def wrap_scalar_pandas_udf(f, return_type):
     def verify_result_length(*a):
         result = f(*a)
         if not hasattr(result, "__len__"):
-            raise TypeError("Return type of the user-defined functon should be 
"
+            raise TypeError("Return type of the user-defined function should 
be "
                             "Pandas.Series, but is {}".format(type(result)))
         if len(result) != len(a[0]):
             raise RuntimeError("Result vector from pandas_udf was not the 
required length: "


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

Reply via email to