当前位置:   article > 正文

头歌:Spark任务提交

头歌:Spark任务提交

第1关:spark-submit提交
任务描述
相关知识
spark-submit参数
计算圆周率
编程要求
测试说明
任务描述
本关任务:学会将程序提交到集群上执行。

相关知识
为了完成本关任务,你需要掌握:1.了解spark-submit的参数。2.学会提交Spark程序在集群运行。


课程视频《spark-submit提交》

spark-submit参数


使用格式:

  1. ./bin/spark-submit
  2.   --class
  3.   --master
  4.   --deploy-mode
  5.   --conf
  6.   ... # other options
  7.   application-jar


计算圆周率
 

  1. cd /opt/spark/dist/bin
  2. ./spark-submit 
  3. --master local 
  4. --class org.apache.spark.examples.SparkPi
  5. /opt/spark/dist/examples/jars/spark-examples_2.11-2.2.0.jar
  6. ./spark-submit --master 本地模式 --class 程序运行的主类名 xxx.jar 

编程要求
根据提示,在右侧编辑器补充代,将程序提交到spark上执行。

测试说明
平台会对你编写的代码进行测试:

jar包所在位置:

/root/project.jar

(点击测评的时候root目录下会有project.jar)

主类:Student
提交模式:local

预期输出:

(bj,88)(sh,67)(gz,92).

  1. #!/bin/bash
  2. cp -r Spark/SparkRDD/target/project.jar /root
  3. cd /opt/spark/dist/bin
  4. #********** Begin **********#
  5. ./spark-submit \
  6. --master local \
  7. --class Student \
  8. /root/project.jar
  9. #********** End **********#

这段脚本首先将 project.jar 复制到 /root 目录下,然后切换到 /opt/spark/dist/bin 目录。在 begin 和 end 之间,使用 spark-submit 命令提交 Spark 程序,其中 --master local 指定了本地模式,--class Student 指定了主类为 Student,最后指定了 jar 包的路径为 /root/project.jar。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/Monodyee/article/detail/524498
推荐阅读
相关标签
  

闽ICP备14008679号