Github user icexelloss commented on a diff in the pull request:
https://github.com/apache/spark/pull/20295#discussion_r172583099
--- Diff: python/pyspark/worker.py ---
@@ -91,10 +92,16 @@ def verify_result_length(*a):
def wrap_grouped_map_pandas_udf(f, return_type):
- def wrapped(*series):
+ def wrapped(key_series, value_series):
import pandas as pd
+ argspec = inspect.getargspec(f)
--- End diff --
Good point. Let me take a look at that.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
