Skip to content

[SPARK-41857][CONNECT][TESTS] Enable test_between_function, test_datetime_functions, test_expr, test_math_functions, test_window_functions_cumulative_sum, test_corr, test_cov, test_crosstab, test_approxQuantile #39359

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
techaddict wants to merge 2 commits into from
Closed

[SPARK-41857][CONNECT][TESTS] Enable test_between_function, test_datetime_functions, test_expr, test_math_functions, test_window_functions_cumulative_sum, test_corr, test_cov, test_crosstab, test_approxQuantile #39359

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
5620f9b
[SPARK-41857][CONNECT][TESTS] Enable test_between_function, test_date…
techaddict Jan 3, 2023
06737d3
address comment
techaddict Jan 3, 2023
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
36 changes: 0 additions & 36 deletions python/pyspark/sql/tests/connect/test_parity_functions.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -60,10 +60,6 @@ def test_assert_true(self):
def test_basic_functions(self):
super().test_basic_functions()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_between_function(self):
super().test_between_function()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_date_add_function(self):
super().test_date_add_function()
Expand All @@ -72,10 +68,6 @@ def test_date_add_function(self):
def test_date_sub_function(self):
super().test_date_sub_function()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_datetime_functions(self):
super().test_datetime_functions()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_dayofweek(self):
super().test_dayofweek()
Expand All @@ -84,10 +76,6 @@ def test_dayofweek(self):
def test_explode(self):
super().test_explode()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_expr(self):
super().test_expr()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_first_last_ignorenulls(self):
super().test_first_last_ignorenulls()
Expand Down Expand Up @@ -128,10 +116,6 @@ def test_lit_np_scalar(self):
def test_map_functions(self):
super().test_map_functions()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_math_functions(self):
super().test_math_functions()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_ndarray_input(self):
super().test_ndarray_input()
Expand Down Expand Up @@ -172,10 +156,6 @@ def test_sorting_functions_with_column(self):
def test_window_functions(self):
super().test_window_functions()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_window_functions_cumulative_sum(self):
super().test_window_functions_cumulative_sum()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_window_functions_without_partitionBy(self):
super().test_window_functions_without_partitionBy()
Expand All @@ -184,18 +164,6 @@ def test_window_functions_without_partitionBy(self):
def test_window_time(self):
super().test_window_time()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_corr(self):
super().test_corr()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_cov(self):
super().test_cov()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_crosstab(self):
super().test_crosstab()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_rand_functions(self):
super().test_rand_functions()
Expand All @@ -208,10 +176,6 @@ def test_reciprocal_trig_functions(self):
def test_sampleby(self):
super().test_sampleby()

@unittest.skip("Fails in Spark Connect, should enable.")
def test_approxQuantile(self):
super().test_approxQuantile()


if __name__ == "__main__":
import unittest
Expand Down