[SPARK-5153][Streaming][Test] Increased timeout to deal with flaky KafkaStreamSuite

tdas · tdas · commit 681f9df47ff4 · 2015-02-03T13:46:02.000-08:00
Timeout increased to allow overloaded Jenkins to cope with delay in topic creation. Author: Tathagata Das <tathagata.das1565@gmail.com> Closes apache#4342 from tdas/SPARK-5153 and squashes the following commits: dc42762 [Tathagata Das] Increased timeout to deal with delays in overloaded Jenkins.
diff --git a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala b/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala
@@ -164,7 +164,7 @@ abstract class KafkaStreamSuiteBase extends FunSuite with Eventually with Loggin
   }
 
   private def waitUntilMetadataIsPropagated(topic: String, partition: Int) {
-    eventually(timeout(1000 milliseconds), interval(100 milliseconds)) {
+    eventually(timeout(10000 milliseconds), interval(100 milliseconds)) {
       assert(
         server.apis.leaderCache.keySet.contains(TopicAndPartition(topic, partition)),
         s"Partition [$topic, $partition] metadata not propagated after timeout"

Original file line number	Diff line number	Diff line change
`@@ -164,7 +164,7 @@ abstract class KafkaStreamSuiteBase extends FunSuite with Eventually with Loggin`
`164`	`164`	`}`
`165`	`165`
`166`	`166`	`private def waitUntilMetadataIsPropagated(topic: String, partition: Int) {`
`167`		`- eventually(timeout(1000 milliseconds), interval(100 milliseconds)) {`
	`167`	`+ eventually(timeout(10000 milliseconds), interval(100 milliseconds)) {`
`168`	`168`	`assert(`
`169`	`169`	`server.apis.leaderCache.keySet.contains(TopicAndPartition(topic, partition)),`
`170`	`170`	`s"Partition [$topic, $partition] metadata not propagated after timeout"`