From 65b76b4de8ebd9d89c9779e3205887ece0cbf663 Mon Sep 17 00:00:00 2001 From: Hari Shreedharan Date: Tue, 22 Jul 2014 22:05:54 -0700 Subject: [PATCH] Fixing the unit test. --- .../apache/spark/streaming/flume/FlumePollingStreamSuite.scala | 2 +- 1 file changed, 1 insertion(+), 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 index ec06b841d2321..739398c7ad92d 100644 --- 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)