This is an automated email from the ASF dual-hosted git repository.
yangjie01 pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 1bd4e4e55cf5 [SPARK-51882][SS][PYTHON][TESTS][4.0] Skip the test
`test_transform_with_state_with_wmark_and_non_event_time`
1bd4e4e55cf5 is described below
commit 1bd4e4e55cf57fca40c36b2ce8c3a526ea526823
Author: yangjie01 <[email protected]>
AuthorDate: Thu Apr 24 08:47:22 2025 +0800
[SPARK-51882][SS][PYTHON][TESTS][4.0] Skip the test
`test_transform_with_state_with_wmark_and_non_event_time`
### What changes were proposed in this pull request?
This pr skips the test case
`test_transform_with_state_with_wmark_and_non_event_time` to prevent the
`pyspark-sql` module tests from timing out.
### Why are the changes needed?
To prevent test timeouts in the `pyspark-sql` module on branch-4.0, note
that this issue does not exist on the master branch.
- https://github.com/apache/spark/actions/runs/14616850457/job/41007046673
- https://github.com/apache/spark/actions/runs/14616825904/job/41006965297
- https://github.com/apache/spark/actions/runs/14617806845/job/41010114906
### Does this PR introduce _any_ user-facing change?
No
### How was this patch tested?
- Pass GitHub Actions
### Was this patch authored or co-authored using generative AI tooling?
No
Closes #50681 from LuciferYang/skip-test.
Authored-by: yangjie01 <[email protected]>
Signed-off-by: yangjie01 <[email protected]>
---
python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py | 1 +
1 file changed, 1 insertion(+)
diff --git
a/python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py
b/python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py
index d3ea5e534443..d5c27806197f 100644
--- a/python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py
+++ b/python/pyspark/sql/tests/pandas/test_pandas_transform_with_state.py
@@ -629,6 +629,7 @@ class TransformWithStateInPandasTestsMixin:
EventTimeStatefulProcessor(), check_results
)
+ @unittest.skip("test will hang during the GA testing, skipping until we
can resolve")
def test_transform_with_state_with_wmark_and_non_event_time(self):
def check_results(batch_df, batch_id):
if batch_id == 0:
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
