Use Thread.yield(), since Thread.sleep(0) is system-dependent

nemccarthy · Apr 17, 2015 · 70ee310 · 70ee310
1 parent 82ee46d
commit 70ee310
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/ReceiverSuite.scala
@@ -176,7 +176,7 @@ class ReceiverSuite extends TestSuiteBase with Timeouts with Serializable {
       blockGenerator.addData(count)
       generatedData += count
       count += 1
-      Thread.sleep(0)
+      Thread.`yield`()
     }
     blockGenerator.stop()