news 2026/1/16 8:56:45

105-Spark之Standalone HA环境搭建过程

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
105-Spark之Standalone HA环境搭建过程

一、高可用的HA

单点故障的问题是无法避免的问题,如何解决这个单点故障的问题,Spark提供了两种方案:
1.基于文件系统的单点恢复(Single-Node Recovery with Local File System)-只能用于开发或测试环境。
2.基于zookeeper的Standby Masters(Standby Masters with ZooKeeper)–可以用于生产环境。
ZooKeeper提供了一个LeaderElection机制,利用这个机制可以保证虽然集群存在多个Master,但是只有一个是Active
的,其他的都是Standby。当Active的Master出现故障时,另外的一个StandbyMaster会被选举出来。由于集群的信息
,包括Worker,Driver和Application的信息都已经持久化到文件系统,因此在切换的过程中只会影响新job的提交,对
于正在进行的job没有任何的影响。加入Zookeeper的集群整体架构如下图所示。

二、搭建步骤

2.1务必确保Zookeeper 和 HDFS 均已经启动!
【如果没有配置过zookeeper的同学可以看我的上一篇文章】

2.2先在spark-env.sh中, 删除:SPARK_MASTER_HOST=node1
原因: 配置文件中固定master是谁, 那么就无法用到zookeeper的动态切换master功能了.

2.3在spark-env.sh中, 在尾行增加下面的配置:

SPARK_DAEMON_JAVA_OPTS="-Dspark.deploy.recoveryMode=ZOOKEEPER -Dspark.deploy.zookeeper.url=node1:2181,node2:2181,node3:2181 -Dspark.deploy.zookeeper.dir=/spark-ha"


2.4将spark-env.sh 分发到每一台服务器上

scpspark-env.sh node2:/export/server/spark/conf/scpspark-env.sh node3:/export/server/spark/conf/


2.5先停止Standalone模式

[hadoop@node1 conf]$cd..[hadoop@node1 spark]$ sbin/stop-all.sh node1: no org.apache.spark.deploy.worker.Worker to stop node3: no org.apache.spark.deploy.worker.Worker to stop node2: no org.apache.spark.deploy.worker.Worker to stop no org.apache.spark.deploy.master.Master to stop[hadoop@node1 spark]$

2.6使用jps查看三个节点机器是否有Master和Worker

2.7在node1节点上启动Master 同时读取worker的配置去启动worker

[hadoop@node1 spark]$ sbin/start-all.sh starting org.apache.spark.deploy.master.Master, logging to /export/server/spark/logs/spark-hadoop-org.apache.spark.deploy.master.Master-1-node1.liushao.cn.out node1: starting org.apache.spark.deploy.worker.Worker, logging to /export/server/spark/logs/spark-hadoop-org.apache.spark.deploy.worker.Worker-1-node1.liushao.cn.out node3: starting org.apache.spark.deploy.worker.Worker, logging to /export/server/spark/logs/spark-hadoop-org.apache.spark.deploy.worker.Worker-1-node3.liushao.cn.out node2: starting org.apache.spark.deploy.worker.Worker, logging to /export/server/spark/logs/spark-hadoop-org.apache.spark.deploy.worker.Worker-1-node2.liushao.cn.out[hadoop@node1 spark]$

2.8 在node2上启动备用的master

[hadoop@node2 ~]$cd/export/server/spark[hadoop@node2 spark]$ sbin/start-master.sh starting org.apache.spark.deploy.master.Master, logging to /export/server/spark/logs/spark-hadoop-org.apache.spark.deploy.master.Master-1-node2.liushao.cn.out[hadoop@node2 spark]$


到此为止就启动了两个master节点 三个worker节点
切记使用jps查看启动进程

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/1/5 13:08:33

互联网大厂Java面试故事:谢飞机的奇妙旅程

互联网大厂Java面试故事:谢飞机的奇妙旅程 第一轮面试:基础知识考察 面试官(严肃):请你讲一下Java中JVM的内存结构是怎样的? 谢飞机(搞笑):JVM的内存结构嘛,就…

作者头像 李华
网站建设 2025/12/16 17:00:06

本地部署LLaMA-Factory并微调大模型

本地部署LLaMA-Factory并微调大模型 在如今人人都能接触大语言模型的时代,真正的问题已经不再是“能不能用”,而是“怎么让它听我的”。我们不再满足于通用模型泛泛的回答——企业需要懂行业术语的客服助手,教育机构想要会讲题的AI老师&…

作者头像 李华
网站建设 2025/12/26 5:22:09

年度福利:如何申请真正可用的一年期免费SSL证书?

一、核心申请渠道(支持一年期)JoySSL(政务/教育类首选)特点:国内CA服务商,提供单域名/通配符免费一年期证书,支持无限续签,兼容主流浏览器。申请步骤:访问 JoySSL官网 &a…

作者头像 李华
网站建设 2026/1/12 11:16:58

Qwen3-VL-30B 4bit量化版发布:单卡部署降本75%

Qwen3-VL-30B 4bit量化版发布:单卡部署降本75% 在自动驾驶系统里,摄像头捕捉到施工围挡遮挡了右转车道——但导航指令还没更新。这时候,AI能不能结合画面和文本语义判断:“前方无法右转,建议提前变道”? …

作者头像 李华
网站建设 2026/1/9 6:12:29

飞腾D3000安装debian12后无法加载RTL8852BE驱动的问题处理

这个 RTL8852BE 在UOS V20 4.19内核或者debian13 6.12内核下面都可以正常驱动但是这个debian12的6.1内核就驱动不了我也找了很多方案,找代码进行编译,最终它应该是合并到了rtl89,但是我编译安装了以后依然无法使用,能看到模块加载了&#xff…

作者头像 李华
网站建设 2025/12/16 16:57:09

LobeChat能否实现语音指令控制?免动手操作场景探索

LobeChat能否实现语音指令控制?免动手操作场景探索 在驾驶途中想查询天气,双手却握着方向盘;在厨房忙着切菜,却记不清菜谱步骤;或是家中长辈不擅长打字,只能对着智能设备干瞪眼——这些日常困境背后&#x…

作者头像 李华