SparkContextMonitor.scala

 private def checkSparkContext(): Unit = {
    val startTime = System.currentTimeMillis()
    log.info("Context creation monitor thread started")
    while (SparkContextBuilder.isContextNotCreated()) {
      Thread.sleep(TimeUnit.SECONDS.toMillis(1))
      val total = System.currentTimeMillis() - startTime
      log.info("Waiting for spark context from {} seconds", TimeUnit.MILLISECONDS.toSeconds(total))
    }

    log.info("Spark context creation took {} seconds", TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis() - startTime))
  }