当前位置: 首页 > news >正文

如何搭建spark yarn模式的集群

1. 环境准备

  • 确保所有节点上安装了 Java(建议 Java 8 或更高版本),并配置好 JAVA_HOME 环境变量。
  • 安装并配置好 Hadoop 集群,保证 HDFS 和 YARN 服务正常运行。

2. 下载并解压 Spark

  • 从 Apache Spark 官方网站(https://spark.apache.org/downloads.html)下载适合你 Hadoop 版本的 Spark 发行版。
  • 将下载的文件解压到所有节点的相同目录,例如 /opt/spark

3. 配置 Spark

3.1 修改 spark-env.sh

在 Spark 安装目录的 conf 文件夹下,复制 spark-env.sh.template 为 spark-env.sh,并进行如下配置:

# 设置 Java 环境变量
export JAVA_HOME=/path/to/java# 设置 Hadoop 配置文件目录
export HADOOP_CONF_DIR=/path/to/hadoop/etc/hadoop# 设置 Spark 日志目录
export SPARK_LOG_DIR=/path/to/spark/logs# 设置 Spark 临时目录
export SPARK_LOCAL_DIRS=/path/to/spark/tmp
3.2 修改 spark-defaults.conf

在 conf 文件夹下,复制 spark-defaults.conf.template 为 spark-defaults.conf,并添加以下内容:

# 设置 Spark 运行模式为 YARN
spark.master    yarn# 设置部署模式为集群模式
spark.submit.deployMode cluster

4. 分发配置文件

将修改后的 spark-env.sh 和 spark-defaults.conf 分发到集群中的所有节点。

5. 启动 Spark 服务

在任意节点上启动 Spark 历史服务器:

/path/to/spark/sbin/start-history-server.sh

6. 测试集群

在任意节点上提交一个简单的 Spark 应用程序进行测试:

/path/to/spark/bin/spark-submit \--class org.apache.spark.examples.SparkPi \--master yarn \--deploy-mode cluster \/path/to/spark/examples/jars/spark-examples_*.jar \10

7. 监控和管理

  • 可以通过 YARN 的资源管理器界面(通常是 http://<resourcemanager-host>:8088)监控 Spark 应用程序的运行情况。
  • 可以通过 Spark 历史服务器界面(通常是 http://<history-server-host>:18080)查看 Spark 应用程序的历史信息。

按照以上步骤,你就可以成功搭建一个 Spark YARN 模式的集群。在实际操作过程中,请根据你的具体环境和需求进行相应的调整。

http://www.xdnf.cn/news/187903.html

相关文章:

  • vite项目tailwindcss4的使用
  • 检查IBM MQ SSL配置是否成功
  • 代码片段存储解决方案ByteStash
  • 每日算法-250428
  • 跨境电商店铺矩阵布局:多账号运营理论到实操全解析
  • JVM 内存分配策略
  • 深海科技服务博客简介
  • 说一下react更新的流程
  • Meta 推出 WebSSL 模型:探索 AI 无语言视觉学习,纯图训练媲美 OpenAI CLIP
  • 详解RabbitMQ工作模式之工作队列模式
  • 盒子模型
  • 图像处理篇---信号与系统的应用
  • Golang|分布式索引架构
  • DDD(领域驱动设计)详解
  • 【C++类与对象高频面试问题总结2】
  • 在VS2022中使用Lua与c交互(二)
  • 读书笔记--华为从偶然到必然之创新与技术开发阅读有感
  • 交换机配置DHCP
  • 使用python实现自动化拉取压缩包并处理流程
  • 深入理解CSS3:Flex/Grid布局、动画与媒体查询实战指南
  • Python初学 有差异的知识点总结(一)
  • 构建“云中”高并发:12306技术改造的系统性启示
  • mac 基于Docker安装minio
  • Flutter介绍、Flutter Windows Android 环境搭建 真机调试
  • ETL架构、数据建模及性能优化实践
  • GPU 架构入门笔记
  • git pull报错error: cannot lock ref ‘refs/remotes/origin/feature/xxx
  • 【C语言】初阶算法相关习题(二)
  • Python-librosa库提取音频数据的MFCC特征
  • 线下CPG零售的核心:POG与销量的循环优化