Skip to content

Commit 443e564

Browse files
committed
Change the check interval to 5ms
1 parent 7aaa2d7 commit 443e564

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

core/src/test/scala/org/apache/spark/util/EventLoopSuite.scala

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ class EventLoopSuite extends FunSuite with Timeouts {
4141
}
4242
eventLoop.start()
4343
(1 to 100).foreach(eventLoop.post)
44-
eventually(timeout(5 seconds), interval(200 millis)) {
44+
eventually(timeout(5 seconds), interval(5 millis)) {
4545
assert((1 to 100) === buffer.toSeq)
4646
}
4747
eventLoop.stop()
@@ -76,7 +76,7 @@ class EventLoopSuite extends FunSuite with Timeouts {
7676
}
7777
eventLoop.start()
7878
eventLoop.post(1)
79-
eventually(timeout(5 seconds), interval(200 millis)) {
79+
eventually(timeout(5 seconds), interval(5 millis)) {
8080
assert(e === receivedError)
8181
}
8282
eventLoop.stop()
@@ -98,7 +98,7 @@ class EventLoopSuite extends FunSuite with Timeouts {
9898
}
9999
eventLoop.start()
100100
eventLoop.post(1)
101-
eventually(timeout(5 seconds), interval(200 millis)) {
101+
eventually(timeout(5 seconds), interval(5 millis)) {
102102
assert(e === receivedError)
103103
assert(eventLoop.isActive)
104104
}
@@ -153,7 +153,7 @@ class EventLoopSuite extends FunSuite with Timeouts {
153153
}.start()
154154
}
155155

156-
eventually(timeout(5 seconds), interval(200 millis)) {
156+
eventually(timeout(5 seconds), interval(5 millis)) {
157157
assert(threadNum * eventsFromEachThread === receivedEventsCount)
158158
}
159159
eventLoop.stop()
@@ -199,7 +199,7 @@ class EventLoopSuite extends FunSuite with Timeouts {
199199
}
200200
eventLoop.start()
201201
eventLoop.post(1)
202-
eventually(timeout(5 seconds), interval(200 millis)) {
202+
eventually(timeout(5 seconds), interval(5 millis)) {
203203
assert(!eventLoop.isActive)
204204
}
205205
}

0 commit comments

Comments
 (0)