Commit 76251c3
committed
[SPARK-28418][PYTHON][SQL] Wait for event process in 'test_query_execution_listener_on_collect'
It fixes a flaky test:
```
ERROR [0.164s]: test_query_execution_listener_on_collect (pyspark.sql.tests.test_dataframe.QueryExecutionListenerTests)
----------------------------------------------------------------------
Traceback (most recent call last):
File "/home/jenkins/python/pyspark/sql/tests/test_dataframe.py", line 758, in test_query_execution_listener_on_collect
"The callback from the query execution listener should be called after 'collect'")
AssertionError: The callback from the query execution listener should be called after 'collect'
```
Seems it can be failed because the event was somehow delayed but checked first.
Manually.
Closes #25177 from HyukjinKwon/SPARK-28418.
Authored-by: HyukjinKwon <gurwls223@apache.org>
Signed-off-by: HyukjinKwon <gurwls223@apache.org>
(cherry picked from commit 66179fa)
Signed-off-by: HyukjinKwon <gurwls223@apache.org>1 parent 198f2f3 commit 76251c3
1 file changed
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
3707 | 3707 | | |
3708 | 3708 | | |
3709 | 3709 | | |
| 3710 | + | |
3710 | 3711 | | |
3711 | 3712 | | |
3712 | 3713 | | |
| |||
3721 | 3722 | | |
3722 | 3723 | | |
3723 | 3724 | | |
| 3725 | + | |
3724 | 3726 | | |
3725 | 3727 | | |
3726 | 3728 | | |
| |||
0 commit comments