Repository: spark Updated Branches: refs/heads/branch-1.6 89a2ddf77 -> 3471244f7
[SPARK-11790][STREAMING][TESTS] Increase the connection timeout Sometimes, EmbeddedZookeeper may need more than 6 seconds to setup up in a slow Jenkins worker. So just increase the timeout, it won't increase the test time if the test passes. Author: Shixiong Zhu <[email protected]> Closes #9778 from zsxwing/SPARK-11790. (cherry picked from commit 3720b1480c7d050ca20f98d65762224ae5639607) Signed-off-by: Andrew Or <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/3471244f Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/3471244f Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/3471244f Branch: refs/heads/branch-1.6 Commit: 3471244f771b60da5524c73685cf2f880a20967f Parents: 89a2ddf Author: Shixiong Zhu <[email protected]> Authored: Tue Nov 17 15:47:39 2015 -0800 Committer: Andrew Or <[email protected]> Committed: Tue Nov 17 15:47:46 2015 -0800 ---------------------------------------------------------------------- .../scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/3471244f/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala ---------------------------------------------------------------------- diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala index c9fd715..86394ea 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala +++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaTestUtils.scala @@ -52,7 +52,7 @@ private[kafka] class KafkaTestUtils extends Logging { // Zookeeper related configurations private val zkHost = "localhost" private var zkPort: Int = 0 - private val zkConnectionTimeout = 6000 + private val zkConnectionTimeout = 60000 private val zkSessionTimeout = 6000 private var zookeeper: EmbeddedZookeeper = _ --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
