spark独立集群搭建

news2025/1/20 15:46:24

spark独立集群搭建(不依赖Hadoop)

1、上传spark-2.4.5-bin-hadoop2.7.tgz至 /usr/local/moudel ,再解压到 /usr/local/soft
    
   tar -zxvf spark-2.4.5-bin-hadoop2.7.tgz -C /usr/local/soft/
   
   
重命名
   mv spark-2.4.5-bin-hadoop2.7/ spark-2.4.5


配置环境变量   
   vim /etc/profile
   
   添加 
   export SPARK_HOME=/usr/local/soft/spark-2.4.5
   
   在path后面添加   :$SPARK_HOME/bin
   

2、进入 spark-2.4.5/conf 目录 ,修改配置文件
   修改主节点配置文件
   cp spark-env.sh.template spark-env.sh
   
   vim spark-env.sh
   
   直接在文件最下方添加
   export SPARK_MASTER_IP=master
   export SPARK_MASTER_PORT=7077

   export SPARK_WORKER_CORES=2
   export SPARK_WORKER_INSTANCES=1
   export SPARK_WORKER_MEMORY=2g
   export JAVA_HOME=/usr/local/soft/jdk1.8.0_171
   
   
   修改从节点配置文件
   cp slaves.template slaves
   
   vim slaves
   
   
   删除localhost 添加
   node1
   node2
   

3、复制到其它节点
   cd /usr/local/soft
   
   scp -r spark-2.4.5/ node1:`pwd`
   scp -r spark-2.4.5/ node2:`pwd`
   

4、在master节点 spark的sbin目录下启动spark
   cd /usr/local/soft/spark-2.4.5/sbin
   
   ./start-all.sh
   


   
   http://master:8080/  访问spark UI       ---- spark独立集群安装完成
   

5、测试
   spark有两种模式 :
   (1) standalone client模式   日志在本地输出,一般用于上线前测试(bin/下执行)

    cd /usr/local/soft/spark-2.4.5/examples/jars

    提交spark任务
    spark-submit --class org.apache.spark.examples.SparkPi --master spark://master:7077 --executor-memory 512m --total-executor-cores 1 spark-examples_2.11-2.4.5.jar 100


    (2) standalone cluster模式   上线使用,不会再本地打印日志 需要到网页查看结果
    

    cd /usr/local/soft/spark-2.4.5/examples/jars
    
    提交spark任务
    spark-submit --class org.apache.spark.examples.SparkPi --master spark://master:7077 --executor-memory 512M --total-executor-cores 1 --deploy-mode cluster spark-examples_2.11-2.4.5.jar 100

------------ 以后都不会使用的  -----------------

===================== 若集群已有yarn , 就不需要再搭建Spark独立集群了  ==================================================================   
以后都会使用 整合 yarn

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1837951.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

003.Linux SSH协议工具

我 的 个 人 主 页:👉👉 失心疯的个人主页 👈👈 入 门 教 程 推 荐 :👉👉 Python零基础入门教程合集 👈👈 虚 拟 环 境 搭 建 :👉&…

项目训练营第一天

项目训练营第一天 springboot后端环境搭建 1、首先需要找文章下载好tomcat、JDK、maven、mysql、IDEA。(软件下载及环境变量配置略) 2、在下载好的IDEA中,选择新建spring initial项目,选定java web,即可新建一个spri…

Pip应用及换源

一、介绍 Pip是Python的包管理器,它用于安装和管理Python的软件包。它是Python标准库的一部分,自从Python 2.7.9和Python 3.4版本开始,它已经内置在Python中,无需单独安装。 通过Pip,用户可以方便地安装、升级和卸载…

健身小程序:智能化助力个人健身旅程

一、智能化功能的核心 健身小程序的智能化功能主要体现在以下几个方面: 智能健身计划推荐:小程序内置了先进的算法,能够根据用户的身体状况、健身目标和时间安排,智能推荐个性化的健身计划。这些计划不仅科学合理,而且…

同三维T80006EHL-4K30CN 单路4K30 HDMI编码器(全国产化)

同三维T80006EHL-4K30CN 单路4K30 HDMI编码器 带1路HDMI环出和1路3.5音频输入,支持4K30,所有元器件全国产 一、 产品简介: T80006EHL-4K30CN 4K编码器(采集盒)是一款全国产化的专业4K HDMI音视频编码产品,…

第29讲:Ceph集群使用RBD块存储设备与K8S的PV集成

文章目录 1.Ceph集群使用RBD块存储与K8S集成简介2.Ceph集群RBD块存储与K8S PV存储卷集成2.1.创建K8S集群PV使用的块存储2.2.创建K8S集群访问RBD块存储设备的认证用户2.3.将认证用户的Key存储在K8S Secret资源中2.4.在K8S集群的所有节点中安装Ceph命令2.5.创建PV及PVC资源使用RB…

【自动驾驶技术】自动驾驶汽车AI芯片汇总——TESLA篇(FSD介绍)

0. 前言 按照国际惯例,首先声明:本文只是我自己学习的理解,虽然参考了他人的宝贵见解及成果,但是内容可能存在不准确的地方。如果发现文中错误,希望批评指正,共同进步。 本篇文章是这个自动驾驶汽车AI芯片系…

【开源许可证】介绍

文章目录 概述具体总结 概述 开源许可证通常可以分为两大类:宽松式许可证及 Copyleft 许可证(也称著作权)。二者的差别主要在于宽松度以及与使用开源软件组件相关的要求和许可权限的多少。 当一个开源组件采用 Copyleft 许可证时&#xff0…

Java开发笔记Ⅲ (一些零碎记录)

一些报错处理 找不到注入的对象 可以在 dao 层 的接口上添加 Repository 注解 common 模块报错 Unable to find main class 由于common中只有一些常量与工具类,不需要主类,故出现该错误时只需删除pom文件中的build标签即可解决 网关模块报错 Failed…

STM32学习笔记(九)--串口 UART/USART详解

(1)配置步骤1.开启RCC外设时钟 开启GPIO以及USART外设2.初始化GPIO 配置TX复用输出 RX输入3.配置USART初始化结构体4.配置串口中断 ITConfig以及NVIC(如果需要USART中断)5.开启USART (2)代码示例 案例1 串…

配对交换00

题目链接 配对交换 题目描述 注意点 num的范围在[0, 2^30 - 1]之间,不会发生整数溢出 解答思路 第一个思路是每次取奇数位和偶数位,将两位上的数字交换并根据其所处的位置求得的值与res相加,重复此过程即可第二个思路是将所有的奇数位和…

Python酷库之旅-比翼双飞情侣库(16)

目录 一、xlwt库的由来 1、背景和需求 2、项目启动 3、功能特点 4、版本兼容性 5、与其他库的关系 6、示例和应用 7、发展历史 二、xlwt库优缺点 1、优点 1-1、简单易用 1-2、功能丰富 1-3、兼容旧版Excel 1-4、社区支持 1-5、稳定性 2、缺点 2-1、不支持.xls…

仓库管理系统的设计

管理员账户功能包括:系统首页,个人中心,管理员管理,公告管理,物资管理,基础数据管理,用户管理 用户账户功能包括:系统首页,个人中心,公告管理,物…

华为HCIP Datacom H12-821 卷5

1.单选题 下列哪种工具不能被 route-policy 的 apply 子句直接引用? A、IP-Prefix B、tag C、community D、origin 正确答案: A 解析: 因route-policy工具中, apply 后面跟的是路由的相关属性。 但是ip-prefix是用来匹配路由的工具。 2…

Java基础学习-流程控制语句-顺序结构-分支结构-循环结构

目录 顺序结构: 分支结构: if语句: 第一种格式: if第二种格式: 案例练习 if第三种格式: switch语句: 格式: switch其他知识点: 循环结构: for循环…

[保姆级教程]uniapp配置vueX

文章目录 注意新建文件简单的使用 注意 uniapp是支持vueX的只需配置一下就好 新建文件 在src文件中,新建一个store(如果有的话跳过) 在store中新建一个js文件,修改js文件名称和选择模板为default 在 uni-app 项目根目录下&…

【C++】拷贝构造函数、拷贝赋值函数与析构函数

C中的拷贝构造函数、拷贝赋值函数与析构函数详解 一、拷贝构造函数(Copy Constructor)二、拷贝赋值函数(Copy Assignment Operator)三、析构函数(Destructor)四、总结 在C中,拷贝构造函数、拷贝…

java-SpringBoot执行定时任务-任务调度-@EnableScheduling和@Scheduled

文章目录 java借助springBoot框架,执行定时任务0. 项目地址1. 需求分析2、新建springBoot项目3. 编写定时任务3.1 开启调度任务3.2 编写定时任务方法 java借助springBoot框架,执行定时任务 0. 项目地址 https://github.com/OrangeHza/JavaDemo 1. 需求…

vue2 TypeError: compiler.plugin is not a function

俩个命令解决: npm i webpack-clilatest npm i webpacklatest

AI项目二十三:危险区域识别系统

若该文为原创文章,转载请注明原文出处。 一、介绍 在IPC监控视频中,很多IPC现在支持区域检测,当在区域内检测到有人闯入时,发送报警并联动报警系统,以保障生命和财产安全具有重大意义。它能够在第一时间检测到人员进入…