override def main(args: Array[String]): Unit = {

        /*

    初始化日志

     */

    val submit = new SparkSubmit() {

      self =>

      override protected def parseArguments(args: Array[String]): SparkSubmitArguments = {

        new SparkSubmitArguments(args) {

          override protected def logInfo(msg: => String): Unit = self.logInfo(msg)

          override protected def logWarning(msg: => String): Unit = self.logWarning(msg)

          .......

　　/**

     *

     *提交任务

     */

    submit.doSubmit(args)

  }

def doSubmit(args: Array[String]): Unit = {

    // Initialize logging if it hasn't been done yet. Keep track of whether logging needs to

    // be reset before the application starts.

    val uninitLog = initializeLogIfNecessary(true, silent = true)

    val appArgs = parseArguments(args)

    if (appArgs.verbose) {

      logInfo(appArgs.toString)

    }

    appArgs.action match {

      case SparkSubmitAction.SUBMIT => submit(appArgs, uninitLog)

      case SparkSubmitAction.KILL => kill(appArgs)

      case SparkSubmitAction.REQUEST_STATUS => requestStatus(appArgs)

      case SparkSubmitAction.PRINT_VERSION => printVersion()

    }

  }

private def runMain(args: SparkSubmitArguments, uninitLog: Boolean): Unit = {

    /*

    childArgs包含任务设置的各项参数 以及mainClass等

    childMainClass 为下图 STANDALONE_CLUSTER_SUBMIT_CLASS

    创建Driver 和Master通信

     */

    val (childArgs, childClasspath, sparkConf, childMainClass) = prepareSubmitEnvironment(args)

    // Let the main class re-initialize the logging system once it starts.

    if (uninitLog) {

      Logging.uninitialize()

    }

    if (args.verbose) {

      logInfo(s"Main class:\n$childMainClass")

      logInfo(s"Arguments:\n${childArgs.mkString("\n")}")

      // sysProps may contain sensitive information, so redact before printing

      logInfo(s"Spark config:\n${Utils.redact(sparkConf.getAll.toMap).mkString("\n")}")

      logInfo(s"Classpath elements:\n${childClasspath.mkString("\n")}")

      logInfo("\n")

    }

    val loader = getSubmitClassLoader(sparkConf)

    for (jar <- childClasspath) {

      addJarToClasspath(jar, loader)

    }

    var mainClass: Class[_] = null

    try {

      mainClass = Utils.classForName(childMainClass)

    } catch {

      case e: ClassNotFoundException =>

        logError(s"Failed to load class $childMainClass.")

        if (childMainClass.contains("thriftserver")) {

          logInfo(s"Failed to load main class $childMainClass.")

          logInfo("You need to build Spark with -Phive and -Phive-thriftserver.")

        }

        throw new SparkUserAppException(CLASS_NOT_FOUND_EXIT_STATUS)

      case e: NoClassDefFoundError =>

        logError(s"Failed to load $childMainClass: ${e.getMessage()}")

        if (e.getMessage.contains("org/apache/hadoop/hive")) {

          logInfo(s"Failed to load hive class.")

          logInfo("You need to build Spark with -Phive and -Phive-thriftserver.")

        }

        throw new SparkUserAppException(CLASS_NOT_FOUND_EXIT_STATUS)

    }