From eef77b862ae6e8a46fb5dc73385ac127a5dd8b92 Mon Sep 17 00:00:00 2001 From: Wei Liu Date: Tue, 23 Jul 2024 21:40:15 -0700 Subject: [PATCH 1/2] skip --- .../sql/tests/connect/streaming/test_parity_listener.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/python/pyspark/sql/tests/connect/streaming/test_parity_listener.py b/python/pyspark/sql/tests/connect/streaming/test_parity_listener.py index eae2b01c55446..f06bdd15f0960 100644 --- a/python/pyspark/sql/tests/connect/streaming/test_parity_listener.py +++ b/python/pyspark/sql/tests/connect/streaming/test_parity_listener.py @@ -15,6 +15,7 @@ # limitations under the License. # import time +import os import pyspark.cloudpickle from pyspark.sql.tests.streaming.test_streaming_listener import StreamingListenerTestsMixin @@ -44,6 +45,9 @@ def onQueryTerminated(self, event): class StreamingListenerParityTests(StreamingListenerTestsMixin, ReusedConnectTestCase): + @unittest.skipIf( + "SPARK_SKIP_CONNECT_COMPAT_TESTS" in os.environ, "Failed with different Client <> Server" + ) def test_listener_events(self): test_listener = TestListenerSpark() From 2a1ebe266beb673fdad1b558203e9e45d43374ad Mon Sep 17 00:00:00 2001 From: Wei Liu Date: Tue, 23 Jul 2024 21:42:05 -0700 Subject: [PATCH 2/2] retrigger --- .../pyspark/sql/tests/connect/streaming/test_parity_listener.py | 1 + 1 file changed, 1 insertion(+) diff --git a/python/pyspark/sql/tests/connect/streaming/test_parity_listener.py b/python/pyspark/sql/tests/connect/streaming/test_parity_listener.py index f06bdd15f0960..99da04315f0ba 100644 --- a/python/pyspark/sql/tests/connect/streaming/test_parity_listener.py +++ b/python/pyspark/sql/tests/connect/streaming/test_parity_listener.py @@ -16,6 +16,7 @@ # import time import os +import unittest import pyspark.cloudpickle from pyspark.sql.tests.streaming.test_streaming_listener import StreamingListenerTestsMixin