Fixing the unit test.

marmbrus · Jul 23, 2014 · 65b76b4 · 65b76b4
1 parent e59cc20
commit 65b76b4
Showing 1 changed file with 1 addition and 1 deletion.
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)