Spark-源码-Spark-Submit 任务提交

Spark 版本:1.3 调用shell, spark-submit.sh args[]   首先是进入 org.apache.spark.deploy.SparkSubmit 类中 调用他的 main() 方法 def main(args: Array[String]): Unit = { // val appArgs = new SparkSubmitArguments(arg
相关文章
相关标签/搜索