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
