We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a9cd5bb commit fb81c4aCopy full SHA for fb81c4a
streaming/src/test/scala/org/apache/spark/streaming/TestSuiteBase.scala
@@ -387,7 +387,7 @@ trait TestSuiteBase extends FunSuite with BeforeAndAfter with Logging {
387
388
// Wait until expected number of output items have been generated
389
val startTime = System.currentTimeMillis()
390
- whileSt (output.size < numExpectedOutput &&
+ while (output.size < numExpectedOutput &&
391
System.currentTimeMillis() - startTime < maxWaitTimeMillis) {
392
logInfo("output.size = " + output.size + ", numExpectedOutput = " + numExpectedOutput)
393
ssc.awaitTerminationOrTimeout(50)
0 commit comments