Revert "[SPARK-49927][SS] pyspark.sql.tests.streaming.test_streaming_…

…listener to wait longer" This reverts commit 2af6536.
panbingkun · Oct 11, 2024 · ed0a63f · ed0a63f
1 parent b93281e
commit ed0a63f
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/python/pyspark/sql/tests/streaming/test_streaming_listener.py b/python/pyspark/sql/tests/streaming/test_streaming_listener.py
@@ -381,8 +381,7 @@ def verify(test_listener):
                     .start()
                 )
                 self.assertTrue(q.isActive)
-                while progress_event is None or progress_event.batchId == 0:
-                    q.awaitTermination(0.5)
+                q.awaitTermination(10)
                 q.stop()
 
                 # Make sure all events are empty