Fix a typo

zsxwing · zsxwing · commit 429728fe0c70 · 2015-09-22T22:56:05.000+08:00
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/util/RecurringTimerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/util/RecurringTimerSuite.scala
@@ -72,7 +72,7 @@ class RecurringTimerSuite extends SparkFunSuite {
     }
     clock.advance(200)
     // When RecurringTimer is awake from clock.waitTillTime, it will call `callback` once.
-    // Then it will find `stopped` is false and exit the loop, but it should call `callback` again
+    // Then it will find `stopped` is true and exit the loop, but it should call `callback` again
     // before exiting its internal thread.
     t.join()
     assert(results === Seq(0L, 100L, 200L))

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ class RecurringTimerSuite extends SparkFunSuite {`
`72`	`72`	`}`
`73`	`73`	`clock.advance(200)`
`74`	`74`	// When RecurringTimer is awake from clock.waitTillTime, it will call `callback` once.
`75`		- // Then it will find `stopped` is false and exit the loop, but it should call `callback` again
	`75`	+ // Then it will find `stopped` is true and exit the loop, but it should call `callback` again
`76`	`76`	`// before exiting its internal thread.`
`77`	`77`	`t.join()`
`78`	`78`	`assert(results === Seq(0L, 100L, 200L))`