Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 1 addition & 6 deletions python/pyspark/sql/tests/connect/test_parity_udf.py
Original file line number Diff line number Diff line change
Expand Up @@ -167,16 +167,11 @@ def test_register_java_function(self):
def test_register_java_udaf(self):
super().test_register_java_udaf()

# TODO(SPARK-42267): support left_outer join type
# TODO(SPARK-42210): implement `spark.udf`
@unittest.skip("Fails in Spark Connect, should enable.")
def test_udf_in_left_outer_join_condition(self):
super().test_udf_in_left_outer_join_condition()

# TODO(SPARK-42267): support left_outer join type
@unittest.skip("Fails in Spark Connect, should enable.")
def test_udf_in_filter_on_top_of_outer_join(self):
super().test_udf_in_filter_on_top_of_outer_join()

# TODO(SPARK-42269): support return type as a collection DataType in DDL strings
@unittest.skip("Fails in Spark Connect, should enable.")
def test_udf_with_string_return_type(self):
Expand Down