fixes #389 - increase SparkReadinessWatcher wait time (#419)

erikerlandson · web-flow · commit bd50627d3474 · 2017-08-08T09:52:39.000-07:00
diff --git a/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/kubernetes/integrationtest/SparkReadinessWatcher.scala b/resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/kubernetes/integrationtest/SparkReadinessWatcher.scala
@@ -37,5 +37,5 @@ private[spark] class SparkReadinessWatcher[T <: HasMetadata] extends Watcher[T]
 
   override def onClose(cause: KubernetesClientException): Unit = {}
 
-  def waitUntilReady(): Boolean = signal.get(30, TimeUnit.SECONDS)
+  def waitUntilReady(): Boolean = signal.get(60, TimeUnit.SECONDS)
 }

Original file line number	Diff line number	Diff line change
`@@ -37,5 +37,5 @@ private[spark] class SparkReadinessWatcher[T <: HasMetadata] extends Watcher[T]`
`37`	`37`
`38`	`38`	`override def onClose(cause: KubernetesClientException): Unit = {}`
`39`	`39`
`40`		`- def waitUntilReady(): Boolean = signal.get(30, TimeUnit.SECONDS)`
	`40`	`+ def waitUntilReady(): Boolean = signal.get(60, TimeUnit.SECONDS)`
`41`	`41`	`}`