Github user jose-torres commented on a diff in the pull request:
https://github.com/apache/spark/pull/21469#discussion_r194232690
--- Diff:
sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamingQueryListenerSuite.scala
---
@@ -231,7 +231,7 @@ class StreamingQueryListenerSuite extends StreamTest
with BeforeAndAfter {
test("event ordering") {
val listener = new EventCollector
withListenerAdded(listener) {
- for (i <- 1 to 100) {
+ for (i <- 1 to 50) {
--- End diff --
Makes sense, and I agree with the implicit claim that this slowdown isn't
too worrying.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
