Spark2.X集群运行模式
发布日期:2021-08-21 13:17:49 浏览次数:19 分类:技术文章

本文共 1790 字,大约阅读时间需要 5 分钟。

 


1.几种运行模式介绍

Spark几种运行模式:

1)Local

2)Standalone(Spark自己的集群管理)

3)Yarn

4)Mesos(Spark初期支持)

IDEA并安装,可以百度一下免费文档。

2.spark Standalone模式配置并测试

1)jdk1.8已经安装

2)scala2.11.8已经安装

3)Hadoop2.6.0已经安装

4)Spark Standalone模式配置与测试

a)配置slave

vi slavesbigdata-pro01.kfk.combigdata-pro02.kfk.combigdata-pro03.kfk.com

 

b)配置spark-env.sh

vi spark-env.shexport JAVA_HOME=/opt/modules/jdk1.8.0_60export SCALA_HOME=/opt/modules/scala-2.11.8SPARK_CONF_DIR=/opt/modules/spark-2.2.0-bin/confSPARK_MASTER_HOST=bigdata-pro02.kfk.comSPARK_MASTER_PORT=7077SPARK_MASTER_WEBUI_PORT=8080SPARK_WORKER_CORES=1SPARK_WORKER_MEMORY=1gSPARK_WORKER_PORT=7078SPARK_WORKER_WEBUI_PORT=8081

 

c)将spark 配置分发到其他节点

scp -r spark-2.2.0-bin bigdata-pro01.kfk.com:/opt/modules/scp -r spark-2.2.0-bin bigdata-pro03.kfk.com:/opt/modules/

 

d)启动spark

sbin/start-all.sh

 

e)客户端测试

bin/spark-shell --master spark://bigdata-pro02.kfk.com:7077

 

d)集群运行

bin/spark-submit --master spark://bigdata-pro02.kfk.com:7077 --deploy-mode cluster /opt/jars/Spark.jar file:///opt/datas/test.txt

 

运行这种方式前要将/opt/jars/Spark.jar分发到所有节点!


3.spark on yarn模式配置并测试

1)注意hadoop配置文件中jdk版本是否与当前jdk版本一致

2)spark on yarn 模式启动并且提交作业

#启动

启动之前先配置HADOOP_CONF_DIR项


bin/spark-shell --master yarn --deploy-mode client

 

#报错

解决方案见博文:

#重新启动yarn和spark

#测试

scala> val rdd = spark.read.textFile("file:///opt/datas/test.txt")rdd: org.apache.spark.sql.Dataset[String] = [value: string]scala> rdd.countres0: Long = 7

 

#提交作业

再这之前请修改一下源代码,并且重新编译上传jar包

bin/spark-submit --class com.zimo.spark.Test --master yarn --deploy-mode cluster /opt/jars/Spark.jar file:///opt/datas/test.txt

 

注意:com.zimo.spark.Test为对应jar包的Class类的路径。


成功!


以上就是博主为大家介绍的这一板块的主要内容,这都是博主自己的学习过程,希望能给大家带来一定的指导作用,有用的还望大家点个支持,如果对你没用也望包涵,有错误烦请指出。如有期待可关注博主以第一时间获取更新哦,谢谢!同时也欢迎转载,但必须在博文明显位置标注原文地址,解释权归博主所有!

转载于:https://www.cnblogs.com/zimo-jing/p/10731058.html

转载地址:https://blog.csdn.net/weixin_33720078/article/details/93674173 如侵犯您的版权,请留言回复原文章的地址,我们会给您删除此文章,给您带来不便请您谅解!

上一篇:Spring 常用注解
下一篇:javascript动画系列第二篇——磁性吸附

发表评论

最新留言

初次前来,多多关照!
[***.217.46.12]2023年02月23日 17时39分28秒

关于作者

    喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!

最新文章

android 适配器接口,RecyclerView在适配器里使用接口将实现交给界面或者用户来处理... 2019-12-19 12:50:14
html下拉列表初始状态,HTML选择:如何设置不会在下拉列表中显示的默认文本?... 2019-12-19 12:50:14
txt文档编辑html不显示图片,Layui富文本编辑器内容不显示,图片上传等问题 2019-12-19 12:50:14
html四张图片拼图,js实现html滑动图片拼图验证 2019-12-19 12:50:14
c语言二维数组的动态创建,王鹏-C++ 动态创建二维数组 (简单版) 2019-12-19 12:50:12
链表c语言 读指针,学习C语言指针和链表的体会 2019-12-19 12:50:12
Android 条件断点,Android DownloadManager 的使用及断点续传-Go语言中文社区 2019-12-19 12:50:12
荣耀电视鸿蒙系统安卓,刚刚!继发布或取代安卓的华为鸿蒙系统后,荣耀“电视”也来了... 2019-12-19 12:50:13
android 点击文本框 不调用键盘,Android点击EditText文本框之外任何地方隐藏键盘 2019-12-19 12:50:13
android 设置网络参数,Android网络请求-sign参数的设置方式 2019-12-19 12:50:13
android+最新手机,最新Android手机性能榜单:骁龙845+8G的它只排第三 2019-12-19 12:50:13
linux kafka 环境搭建,centos7搭建kafka集群 2019-12-19 12:50:10
linux配置一个ip san存储服务器,网络存储服务ip-san搭建 2019-12-19 12:50:11
linux删除大量过期文件,linux删除大量文件的6种方法 2019-12-19 12:50:11
linux 反编译 obj,objdump反汇编 2019-12-19 12:50:11
Linux7防火墙情况,【整理】CentOS 7防火墙使用 | 勤奋的小青蛙 2019-12-19 12:50:11
浏览器 拒绝连接linux ip,192.168.1.1拒绝了我们的连接请求怎么办? 2019-12-19 12:50:12
linux基础简介,Linux基础-Bash简介 2019-12-19 12:50:12
linux64 编译 32,在64位主机上编译产生32位的目标代码 2019-12-19 12:50:09
不用系统盘怎么做linux,Linux下制作U盘系统安装盘 2019-12-19 12:50:09