Increase timeout

zsxwing · zsxwing · commit 9ff2ed48062f · 2016-11-29T10:30:15.000-08:00
diff --git a/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala b/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala
@@ -344,7 +344,7 @@ class KafkaTestUtils extends Logging {
       case _ =>
         false
     }
-    eventually(timeout(10.seconds)) {
+    eventually(timeout(60.seconds)) {
       assert(isPropagated, s"Partition [$topic, $partition] metadata not propagated after timeout")
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -344,7 +344,7 @@ class KafkaTestUtils extends Logging {`
`344`	`344`	`case _ =>`
`345`	`345`	`false`
`346`	`346`	`}`
`347`		`- eventually(timeout(10.seconds)) {`
	`347`	`+ eventually(timeout(60.seconds)) {`
`348`	`348`	`assert(isPropagated, s"Partition [$topic, $partition] metadata not propagated after timeout")`
`349`	`349`	`}`
`350`	`350`	`}`