diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-02-03 13:46:02 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-02-03 13:46:24 -0800 |
| commit | 36c2994304e1bad588d18c5cd9044e7d3617fcd5 (patch) | |
| tree | 1ca2815d7062de52ebe70dcbecbdfd89782408c2 /external/kafka/src | |
| parent | 591cd8393aa487bfb249f6b0d6df9df2a7a45acd (diff) | |
| download | spark-36c2994304e1bad588d18c5cd9044e7d3617fcd5.tar.gz spark-36c2994304e1bad588d18c5cd9044e7d3617fcd5.tar.bz2 spark-36c2994304e1bad588d18c5cd9044e7d3617fcd5.zip | |
[SPARK-5153][Streaming][Test] Increased timeout to deal with flaky KafkaStreamSuite
Timeout increased to allow overloaded Jenkins to cope with delay in topic creation.
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #4342 from tdas/SPARK-5153 and squashes the following commits:
dc42762 [Tathagata Das] Increased timeout to deal with delays in overloaded Jenkins.
(cherry picked from commit 681f9df47ff40f7b0d9175d835e9758d33a13a06)
Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
Diffstat (limited to 'external/kafka/src')
| -rw-r--r-- | external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 index b19c053ebf..0817c56d8f 100644 --- 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" |