Fixing the unit test.

harishreedharan · harishreedharan · commit 65b76b4de8eb · 2014-07-22T22:05:54.000-07:00
diff --git a/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumePollingStreamSuite.scala b/external/flume/src/test/scala/org/apache/spark/streaming/flume/FlumePollingStreamSuite.scala
@@ -127,7 +127,7 @@ import org.apache.spark.streaming.flume.sink._
       executorCompletion.take()
     }
     val startTime = System.currentTimeMillis()
-    while (outputBuffer.size < 5 * channels.size &&
+    while (outputBuffer.size < 5 &&
       System.currentTimeMillis() - startTime < 15000) {
       logInfo("output.size = " + outputBuffer.size)
       Thread.sleep(100)

Original file line number	Diff line number	Diff line change
`@@ -127,7 +127,7 @@ import org.apache.spark.streaming.flume.sink._`
`127`	`127`	`executorCompletion.take()`
`128`	`128`	`}`
`129`	`129`	`val startTime = System.currentTimeMillis()`
`130`		`- while (outputBuffer.size < 5 * channels.size &&`
	`130`	`+ while (outputBuffer.size < 5 &&`
`131`	`131`	`System.currentTimeMillis() - startTime < 15000) {`
`132`	`132`	`logInfo("output.size = " + outputBuffer.size)`
`133`	`133`	`Thread.sleep(100)`