Repository: spark
Updated Branches:
  refs/heads/master e29656f8e -> 3720b1480


[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.


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/3720b148
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/3720b148
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/3720b148

Branch: refs/heads/master
Commit: 3720b1480c7d050ca20f98d65762224ae5639607
Parents: e29656f
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:39 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/3720b148/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]

Reply via email to