Remove arbitrary thread timing / cooperation code

David McGuire · David McGuire · commit 8f2934b034dd · 2015-04-17T23:49:11.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,6 @@ class ReceiverSuite extends TestSuiteBase with Timeouts with Serializable {
       blockGenerator.addData(count)
       generatedData += count
       count += 1
-      Thread.`yield`()
     }
     blockGenerator.stop()
 

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