Skip to content

Commit d5e6948

Browse files
squitocloud-fan
authored andcommitted
[SPARK-25805][SQL][TEST] Fix test for SPARK-25159
The original test would sometimes fail if the listener bus did not keep up, so just wait till the listener bus is empty. Tested by adding a sleep in the listener, which made the test consistently fail without the fix, but pass consistently after the fix. Closes #22799 from squito/SPARK-25805. Authored-by: Imran Rashid <[email protected]> Signed-off-by: Wenchen Fan <[email protected]> (cherry picked from commit 78c8bd2) Signed-off-by: Wenchen Fan <[email protected]>
1 parent 4099565 commit d5e6948

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2549,6 +2549,7 @@ class DataFrameSuite extends QueryTest with SharedSQLContext {
25492549

25502550
val df = spark.read.json(path.getCanonicalPath)
25512551
assert(df.columns === Array("i", "p"))
2552+
spark.sparkContext.listenerBus.waitUntilEmpty(10000)
25522553
assert(numJobs == 1)
25532554
}
25542555
}

0 commit comments

Comments
 (0)