Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19681#discussion_r149780801
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/execution/metric/SQLMetricsSuite.scala
---
@@ -420,21 +428,19 @@ class SQLMetricsSuite extends SparkFunSuite with
SQLMetricsTestUtils with Shared
withTempPath { file =>
// person creates a temporary view. get the DF before listing
previous execution IDs
val data = person.select('name)
- sparkContext.listenerBus.waitUntilEmpty(10000)
--- End diff --
don't you still need this `waitUntilEmpty`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
