news 2026/4/28 19:58:58

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/4/25 21:50:08

使用 TensorRT-LLM 高性能部署开源大模型

使用 TensorRT-LLM 高性能部署开源大模型 在生成式 AI 爆发的今天,企业不再只是“能不能用上大模型”,而是“能不能高效、低成本地服务成千上万用户”。像 Llama 3、Qwen 和 Mistral 这样的开源模型已经具备媲美闭源商业产品的语言能力,但若推…

作者头像 李华
网站建设 2026/4/23 15:57:35

LobeChat能否部署在NAS设备上?家庭私有云运行测试

LobeChat能否部署在NAS设备上?家庭私有云运行测试在智能设备日益普及的今天,越来越多用户开始关注一个问题:能不能让AI助手真正属于我自己? 不依赖云端API、不上传对话记录、不用为每次提问付费——这种对“数字主权”的追求&…

作者头像 李华
网站建设 2026/4/26 1:03:52

让微信公众号成为 AI 智能体:从内容沉淀到智能问答的一次升级

让微信公众号成为 AI 智能体:从内容沉淀到智能问答的一次升级 大家好,我是星哥,之前写了一篇文章自己手撸一个AI智能体—跟创业大佬对话,今天继续想做一个智能体。 我一直在折腾公众号,写了不少内容,沉淀…

作者头像 李华
网站建设 2026/4/22 14:56:01

Langflow:拖拽式AI工作流颠覆编程

Langflow:拖拽式AI工作流如何重塑开发体验 你有没有试过花几个小时写完一段 LangChain 代码,结果运行时发现提示词拼错了变量?或者团队里的产品经理拿着流程图问:“这个逻辑明明很简单,为什么还要两周才能上线&#xf…

作者头像 李华
网站建设 2026/4/27 8:30:25

LLaMA-Factory:高效微调百款大模型的工具

LLaMA-Factory:让百款大模型微调变得触手可及 在当前大模型技术飞速演进的背景下,如何快速、低成本地定制专属模型,已成为研究者与开发者共同关注的核心命题。面对动辄数十GB显存、复杂依赖和陡峭学习曲线的传统微调流程,一个真正…

作者头像 李华