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

Reply via email to