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

David McGuire · David McGuire · commit 70ee3103b574 · 2015-04-17T12:37:12.000-07:00
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()
 

Original file line number	Diff line number	Diff line change
`@@ -176,7 +176,7 @@ class ReceiverSuite extends TestSuiteBase with Timeouts with Serializable {`
`176`	`176`	`blockGenerator.addData(count)`
`177`	`177`	`generatedData += count`
`178`	`178`	`count += 1`
`179`		`- Thread.sleep(0)`
	`179`	+ Thread.`yield`()
`180`	`180`	`}`
`181`	`181`	`blockGenerator.stop()`
`182`	`182`