LucaCanali commented on code in PR #33559:
URL: https://github.com/apache/spark/pull/33559#discussion_r842774988
##########
sql/core/src/main/scala/org/apache/spark/sql/execution/python/FlatMapGroupsInPandasExec.scala:
##########
@@ -89,7 +89,8 @@ case class FlatMapGroupsInPandasExec(
Array(argOffsets),
Review Comment:
I'd like to clarify that the proposed solution for the failing test is to
move the test to a Python test in python/pyspark/sql/tests/test_pandas_udf.py
where it runs OK. I would (try to) argue that the issue may come for the way
the Python UDF test in udf-aggregates_part3.sql is executed via Scala and the
fact that that particular test is referring to `udf` twice: `udf((select
udf(count(*))` which apparently creates an issue there, while it works fine in
a Python test.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
