This is an automated email from the ASF dual-hosted git repository.

gurwls223 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 b0f98f372bbd [SPARK-54599][PYTHON][FOLLOWUP][4.0] Remove another error 
message check to make CI happy
b0f98f372bbd is described below

commit b0f98f372bbd5346a4b7d8b6b7148bd138a22542
Author: Tian Gao <[email protected]>
AuthorDate: Fri Feb 20 11:49:21 2026 +0900

    [SPARK-54599][PYTHON][FOLLOWUP][4.0] Remove another error message check to 
make CI happy
    
    ### What changes were proposed in this pull request?
    
    Remove an error message check for client tests for branch-4.0.
    
    ### Why are the changes needed?
    
    The reason is the same as #54353
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    This time I ran the 4.0 client + master server on my own repo and it's 
clean - 
https://github.com/gaogaotiantian/spark/actions/runs/22202142365/job/64217487958
    
    ### Was this patch authored or co-authored using generative AI tooling?
    
    No.
    
    Closes #54385 from gaogaotiantian/4.0-fix-exception-tests.
    
    Authored-by: Tian Gao <[email protected]>
    Signed-off-by: Hyukjin Kwon <[email protected]>
---
 python/pyspark/sql/tests/streaming/test_streaming_foreach_batch.py | 2 --
 1 file changed, 2 deletions(-)

diff --git a/python/pyspark/sql/tests/streaming/test_streaming_foreach_batch.py 
b/python/pyspark/sql/tests/streaming/test_streaming_foreach_batch.py
index fbc9baccbc90..9cb77a3d4a65 100644
--- a/python/pyspark/sql/tests/streaming/test_streaming_foreach_batch.py
+++ b/python/pyspark/sql/tests/streaming/test_streaming_foreach_batch.py
@@ -81,8 +81,6 @@ class StreamingTestsForeachBatchMixin:
         except StreamingQueryException as e:
             err_msg = str(e)
             self.assertTrue("this should fail" in err_msg)
-            # check for foreachBatch error class
-            self.assertTrue("FOREACH_BATCH_USER_FUNCTION_ERROR" in err_msg)
         finally:
             if q:
                 q.stop()


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to