当前位置:网站首页>spark集群部署(第三弹)
spark集群部署(第三弹)
2022-08-05 08:07:00 【发量不足】
目录
3.测试spark HA集群,为演示是否解决单点故障问题,关闭master节点的master进程

spark集群部署
1 修改spark-env.sh配置文件
$ssh master
$cd opt/module/spark/conf
$vi spark-env.sh

步骤1 将指定master节点配置参数注释‘#’,添加SPARK_DAEMON_JAVA_OPTS配置参数
export JAVA_HOME=/opt/module/jdk1.8.0_144
#export SPARK_MASTER_HOST=master
export SPARK_MASTER_PORT=7077
export SPARK_DAEMON_JAVA_OPTS="-Dspark.deploy.recoveryMode=ZOOKEEPER
-Dspark.deploy.zookeeper.url=master:2181,slave1:2181,slave2:2181
-Dspark.deploy.zookeeper.dir=/spark"
(1)spark.deploy.recoveryMode=ZOOKEEPER:设置zookeeper去启用备用master模式
(2)spark.deploy.zookeeper.url=master:指定zookeeper的server地址
(3)spark.deploy.zookeeper.dir:保存集群元数据信息的文件和目录

将spark-env.sh分发至slave1和slave2节点上,保证配置文件统一
scp spark-env.sh slave1:/opt/module/spark/conf/
scp spark-env.sh slave2:/opt/module/spark/conf/

2 启动spark HA集群
$cd /opt/module/zookeeper/bin
$ zkServer.sh start





解决:配置问题,自己把spark-env.sh配置内容里的横杆空格了

问题2 在slave1节点启动master服务报 stop it first(意思是要你先停止这个,才能开启master,也可以不去停止)

$cd opt/software/spark
$sbin/stop-all.sh

解决以上的问题后,重新在master节点启动spark集群与在slave节点单独启动master服务
在master节点上单独启动spark服务
$/opt/module/spark/sbin/start-all.sh

在slave1节点上单独启动Master服务
$/opt/module/spark/sbin/start-master.sh

步骤2 访问http://192.168.196.102(slave1):8080,查看备用master节点状态
Status:STANDBY # 说明spark HA配置完成

3.测试spark HA集群,为演示是否解决单点故障问题,关闭master节点的master进程
$ /opt/module/spark/sbin/stop-master.sh
边栏推荐
- v-if/v-else determines whether to display according to the calculation
- egg框架中解决跨域的三种方案
- C-Eighty seven(背包+bitset)
- [Repost] Marry a man must marry a man whose salary is at least 3571.4 yuan higher than yours
- JS语法使用
- Stored procedure writing experience and optimization measures
- 请问my sql如何把两个表的内容集合在一起啊?
- [Structural Internal Power Cultivation] Structural Realization Stages (2)
- Use of thread pool (combined with Future/Callable)
- Redis implements distributed lock-principle-detailed explanation of the problem
猜你喜欢
随机推荐
CROS和JSONP配置
配合屏幕录像专家,又小又清晰!
撕裂寂寞
强网杯2022 pwn 赛题解析——house_of_cat
Mysql 死锁和死锁的解决方案
爬虫之验证码
基于 Docker 快速使用远程(云)数据库
长期招聘嵌入式开发-深圳宝安
C-Eighty seven(背包+bitset)
【结构体内功修炼】结构体实现位段(二)
数据库——概述
egg框架中解决跨域的三种方案
moment的使用
Discourse 清理存储空间的方法
学习机赛道加速:请“卷”产品,不要“卷”营销
uniapp time component encapsulates year-month-day-hour-minute-second
[Structure internal power practice] Structure memory alignment (1)
彩绘漂亮MM集
Unity—物理引擎+“武器模块”
Redis实现分布式锁-原理-问题详解









