Revert "Remove last remaining sleep() call"

JoshRosen · JoshRosen · commit fffc51c97bc0 · 2015-01-04T23:54:18.000-08:00
This reverts commit dbb8247.
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/CheckpointSuite.scala
@@ -372,7 +372,7 @@ class CheckpointSuite extends TestSuiteBase {
         }
         clock.addToTime(batchDuration.milliseconds)
         waiter.waitForTotalBatchesStarted(3, batchDuration * 5)
-        assert(waiter.getNumCompletedBatches === 2)
+        Thread.sleep(1000) // To wait for execution to actually begin
         logInfo("Output after first start = " + outputStream.output.mkString("[", ", ", "]"))
         assert(outputStream.output.size > 0, "No files processed before restart")
         ssc.stop()

Original file line number	Diff line number	Diff line change
`@@ -372,7 +372,7 @@ class CheckpointSuite extends TestSuiteBase {`
`372`	`372`	`}`
`373`	`373`	`clock.addToTime(batchDuration.milliseconds)`
`374`	`374`	`waiter.waitForTotalBatchesStarted(3, batchDuration * 5)`
`375`		`- assert(waiter.getNumCompletedBatches === 2)`
	`375`	`+ Thread.sleep(1000) // To wait for execution to actually begin`
`376`	`376`	`logInfo("Output after first start = " + outputStream.output.mkString("[", ", ", "]"))`
`377`	`377`	`assert(outputStream.output.size > 0, "No files processed before restart")`
`378`	`378`	`ssc.stop()`