Fix the unit test

apache · Apr 22, 2015 · 5688702 · 5688702
1 parent ddf741a
commit 5688702
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ming/src/test/scala/org/apache/spark/streaming/ui/StreamingJobProgressListenerSuite.scala b/...ming/src/test/scala/org/apache/spark/streaming/ui/StreamingJobProgressListenerSuite.scala
@@ -100,7 +100,7 @@ class StreamingJobProgressListenerSuite extends TestSuiteBase with Matchers {
 
   test("Remove the old completed batches when exceeding the limit") {
     val ssc = setupStreams(input, operation)
-    val limit = ssc.conf.getInt("spark.streaming.ui.retainedBatches", 100)
+    val limit = ssc.conf.getInt("spark.streaming.ui.retainedBatches", 1000)
     val listener = new StreamingJobProgressListener(ssc)
 
     val receivedBlockInfo = Map(