This is an automated email from the ASF dual-hosted git repository. gurwls223 pushed a commit to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-3.2 by this push: new bc9a5d7689b [SPARK-39972][PYTHON][SQL][TESTS] Revert the test case of SPARK-39962 in branch-3.2 and branch-3.1 bc9a5d7689b is described below commit bc9a5d7689b9ac7dbfbdfc4e61741a1ceaa0b9ac Author: Hyukjin Kwon <gurwls...@apache.org> AuthorDate: Thu Aug 4 10:51:11 2022 +0900 [SPARK-39972][PYTHON][SQL][TESTS] Revert the test case of SPARK-39962 in branch-3.2 and branch-3.1 ### What changes were proposed in this pull request? This PR reverts the test in https://github.com/apache/spark/pull/37390 in branch-3.2 and branch-3.1 because testing util does not exist in branch-3.2 and branch-3.1. ### Why are the changes needed? See https://github.com/apache/spark/pull/37390#issuecomment-1204658808 ### Does this PR introduce _any_ user-facing change? No, test-only. ### How was this patch tested? Logically clean revert. Closes #37401 from HyukjinKwon/SPARK-39972. Authored-by: Hyukjin Kwon <gurwls...@apache.org> Signed-off-by: Hyukjin Kwon <gurwls...@apache.org> --- .../apache/spark/sql/execution/python/PythonUDFSuite.scala | 13 ------------- 1 file changed, 13 deletions(-) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/python/PythonUDFSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/python/PythonUDFSuite.scala index 4ad7f901053..45b57207c57 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/python/PythonUDFSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/python/PythonUDFSuite.scala @@ -71,17 +71,4 @@ class PythonUDFSuite extends QueryTest with SharedSparkSession { pythonTestUDF(count(pythonTestUDF(base("a") + 1)))) checkAnswer(df1, df2) } - - test("SPARK-39962: Global aggregation of Pandas UDF should respect the column order") { - assume(shouldTestGroupedAggPandasUDFs) - val df = Seq[(java.lang.Integer, java.lang.Integer)]((1, null)).toDF("a", "b") - - val pandasTestUDF = TestGroupedAggPandasUDF(name = "pandas_udf") - val reorderedDf = df.select("b", "a") - val actual = reorderedDf.agg( - pandasTestUDF(reorderedDf("a")), pandasTestUDF(reorderedDf("b"))) - val expected = df.agg(pandasTestUDF(df("a")), pandasTestUDF(df("b"))) - - checkAnswer(actual, expected) - } } --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org