Github user sanjay-saxena commented on a diff in the pull request:
https://github.com/apache/incubator-toree/pull/147#discussion_r152348081
--- Diff: kernel/src/main/scala/org/apache/toree/kernel/api/Kernel.scala ---
@@ -403,15 +403,17 @@ class Kernel (
case Some(master) if !master.contains("local") =>
// when connecting to a remote cluster, the first call to
getOrCreate
// may create a session and take a long time, so this starts a
future
- // to get the session. if it take longer than 100 ms, then print a
+ // to get the session. if it take longer than specified timeout,
then print a
// message to the user that Spark is starting.
import scala.concurrent.ExecutionContext.Implicits.global
val sessionFuture = Future {
SparkSession.builder.config(defaultSparkConf).getOrCreate
}
try {
- Await.result(sessionFuture, Duration(100, TimeUnit.MILLISECONDS))
+ val timeout =
config.getInt("spark_context_intialization_timeout")
--- End diff --
Sounds good.
---
