Crash about sparklens HOT 2 CLOSED

  def computeCriticalTimeForJob(): Long = {
    if (stageMap.isEmpty) {
      0
    } else {
      val maxStageID = stageMap.map(x => x._1).max
      val data  = stageMap.map(x =>
        ( x._1,
          (
            x._2.parentStageIDs,
            x._2.stageMetrics.map(AggregateMetrics.executorRuntime).max
          )
        )
      )
      criticalTime(maxStageID, data)
    }
  }