临时笔记

  def main(argStrings: Array[String]) {
    // 读取以spark.开头的配置属性
    val conf = new SparkConf
    // 检查环境变量:SPARK_MASTER_HOST、SPARK_MASTER_PORT、SPARK_MASTER_WEBUI_PORT
    
// 再检查配置属性:master.ui.port
    
// 检查其他master配置,如命令行属性
    val args = new MasterArguments(argStrings, conf)
    // 配置akka,创建spark master actor
    val (actorSystem, _, _) = startSystemAndActor(args.host, args.port, args.webUiPort, conf)
    actorSystem.awaitTermination()
  }

 

相关文章:

  • 2021-11-19
  • 2021-08-04
  • 2021-11-19
  • 2021-11-19
  • 2021-12-07
  • 2022-01-14
  • 2021-11-21
  • 2021-09-05
猜你喜欢
  • 2021-11-19
  • 2022-01-07
  • 2022-12-23
  • 2021-08-02
  • 2022-12-23
  • 2021-08-19
  • 2021-04-03
相关资源
相似解决方案