This is an automated email from the ASF dual-hosted git repository. gurwls223 pushed a commit to branch branch-3.5 in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-3.5 by this push: new ac4c5d618e02 [SPARK-48087][PYTHON][TESTS][3.5] Remove obsolete comment about UDTF test ac4c5d618e02 is described below commit ac4c5d618e02281a3748cd0431539019a140ec27 Author: Hyukjin Kwon <gurwls...@apache.org> AuthorDate: Wed May 8 20:00:43 2024 +0900 [SPARK-48087][PYTHON][TESTS][3.5] Remove obsolete comment about UDTF test ### What changes were proposed in this pull request? UDTF is experimental, and its design has not been fully implemented yet. Not documented either so it's left as a breaking change. ### Why are the changes needed? To remove the obsolete comment. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? N/A ### Was this patch authored or co-authored using generative AI tooling? No. Closes #46473 from HyukjinKwon/SPARK-48087. Authored-by: Hyukjin Kwon <gurwls...@apache.org> Signed-off-by: Hyukjin Kwon <gurwls...@apache.org> --- python/pyspark/sql/tests/connect/test_parity_udtf.py | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/python/pyspark/sql/tests/connect/test_parity_udtf.py b/python/pyspark/sql/tests/connect/test_parity_udtf.py index 5955b502e48b..ebf7692a20cd 100644 --- a/python/pyspark/sql/tests/connect/test_parity_udtf.py +++ b/python/pyspark/sql/tests/connect/test_parity_udtf.py @@ -59,84 +59,72 @@ class UDTFParityTests(BaseUDTFTestsMixin, ReusedConnectTestCase): ): TestUDTF(lit(1)).collect() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_udtf_init_with_additional_args(self): super(UDTFParityTests, self).test_udtf_init_with_additional_args() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_udtf_with_wrong_num_input(self): super(UDTFParityTests, self).test_udtf_with_wrong_num_input() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_array_output_type_casting(self): super(UDTFParityTests, self).test_array_output_type_casting() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_map_output_type_casting(self): super(UDTFParityTests, self).test_map_output_type_casting() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_numeric_output_type_casting(self): super(UDTFParityTests, self).test_numeric_output_type_casting() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_numeric_output_type_casting(self): super(UDTFParityTests, self).test_numeric_output_type_casting() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_numeric_string_output_type_casting(self): super(UDTFParityTests, self).test_numeric_string_output_type_casting() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_string_output_type_casting(self): super(UDTFParityTests, self).test_string_output_type_casting() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_string_output_type_casting(self): super(UDTFParityTests, self).test_string_output_type_casting() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_struct_output_type_casting_dict(self): super(UDTFParityTests, self).test_struct_output_type_casting_dict() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) def test_udtf_init_with_additional_args(self): super(UDTFParityTests, self).test_udtf_init_with_additional_args() - # TODO(SPARK-48087): Reenable this test case @unittest.skipIf( "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" ) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org