Python搭建Spark分布式集群環(huán)境
前言
Apache Spark 是一個新興的大數(shù)據(jù)處理通用引擎,提供了分布式的內(nèi)存抽象。Spark 最大的特點就是快,可比 Hadoop MapReduce 的處理速度快 100 倍。本文沒有使用一臺電腦上構(gòu)建多個虛擬機的方法來模擬集群,而是使用三臺電腦來搭建一個小型分布式集群環(huán)境安裝。
本教程采用Spark2.0以上版本(比如Spark2.0.2、Spark2.1.0等)搭建集群,同樣適用于搭建Spark1.6.2集群。
安裝Hadoop并搭建好Hadoop集群環(huán)境
Spark分布式集群的安裝環(huán)境,需要事先配置好Hadoop的分布式集群環(huán)境。
安裝Spark
這里采用3臺機器(節(jié)點)作為實例來演示如何搭建Spark集群,其中1臺機器(節(jié)點)作為Master節(jié)點,另外兩臺機器(節(jié)點)作為Slave節(jié)點(即作為Worker節(jié)點),主機名分別為Slave01和Slave02。
在Master節(jié)點機器上,訪問Spark官方下載地址,按照如下圖下載。

下載完成后,執(zhí)行如下命令:
sudo tar -zxf ~/下載/spark-2.0.2-bin-without-hadoop.tgz -C /usr/local/ cd /usr/local sudo mv ./spark-2.0.2-bin-without-hadoop/ ./spark sudo chown -R hadoop ./spark
配置環(huán)境變量
在Mster節(jié)點主機的終端中執(zhí)行如下命令:
vim ~/.bashrc
在.bashrc添加如下配置:
export SPARK_HOME=/usr/local/spark export PATH=$PATH:$SPARK_HOME/bin:$SPARK_HOME/sbin
執(zhí)行如下命令使得配置立即生效:
source ~/.bashrc
Spark配置
在Master節(jié)點主機上進行如下操作:
配置slaves文件
將 slaves.template 拷貝到 slaves
cd /usr/local/spark/ cp ./conf/slaves.template ./conf/slaves
slaves文件設(shè)置Worker節(jié)點。編輯slaves內(nèi)容,把默認內(nèi)容localhost替換成如下內(nèi)容:
slave01 slave02
配置spark-env.sh文件
將 spark-env.sh.template 拷貝到 spark-env.sh
cp ./conf/spark-env.sh.template ./conf/spark-env.sh
編輯spark-env.sh,添加如下內(nèi)容:
export SPARK_DIST_CLASSPATH=$(/usr/local/hadoop/bin/hadoop classpath) export HADOOP_CONF_DIR=/usr/local/hadoop/etc/hadoop export SPARK_MASTER_IP=192.168.1.104
SPARK_MASTER_IP 指定 Spark 集群 Master 節(jié)點的 IP 地址;
配置好后,將Master主機上的/usr/local/spark文件夾復(fù)制到各個節(jié)點上。在Master主機上執(zhí)行如下命令:
cd /usr/local/ tar -zcf ~/spark.master.tar.gz ./spark cd ~ scp ./spark.master.tar.gz slave01:/home/hadoop scp ./spark.master.tar.gz slave02:/home/hadoop
在slave01,slave02節(jié)點上分別執(zhí)行下面同樣的操作:
sudo rm -rf /usr/local/spark/ sudo tar -zxf ~/spark.master.tar.gz -C /usr/local sudo chown -R hadoop /usr/local/spark
啟動Spark集群
啟動Hadoop集群
啟動Spark集群前,要先啟動Hadoop集群。在Master節(jié)點主機上運行如下命令:
cd /usr/local/hadoop/ sbin/start-all.sh
啟動Spark集群
1.啟動Master節(jié)點
在Master節(jié)點主機上運行如下命令:
cd /usr/local/spark/ sbin/start-master.sh
在Master節(jié)點上運行jps命令,可以看到多了個Master進程:
15093 Jps 14343 SecondaryNameNode 14121 NameNode 14891 Master 14509 ResourceManager
2.啟動所有Slave節(jié)點
在Master節(jié)點主機上運行如下命令:
sbin/start-slaves.sh
分別在slave01、slave02節(jié)點上運行jps命令,可以看到多了個Worker進程
37553 DataNode 37684 NodeManager 37876 Worker 37924 Jps
3.在瀏覽器上查看Spark獨立集群管理器的集群信息
在master主機上打開瀏覽器,訪問http://master:8080,如下圖:

關(guān)閉Spark集群
1.關(guān)閉Master節(jié)點
sbin/stop-master.sh
2.關(guān)閉Worker節(jié)點
sbin/stop-slaves.sh
3.關(guān)閉Hadoop集群
cd /usr/local/hadoop/ sbin/stop-all.sh
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
matplotlib實現(xiàn)自定義散點形狀marker的3種方法
本文主要介紹了matplotlib實現(xiàn)自定義散點形狀marker的3種方法,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-10-10
python中PS 圖像調(diào)整算法原理之亮度調(diào)整
這篇文章主要介紹了python中PS 圖像調(diào)整算法原理之亮度調(diào)整,本文給大家介紹的非常詳細,具有一定的參考借鑒價值,需要的朋友可以參考下2019-06-06
Python的pytest測試框架中fixture的使用詳解
這篇文章主要介紹了pytest中fixture的使用詳解,pytest是一個非常成熟的全功能的Python測試框架,能夠支持簡單的單元測試和復(fù)雜的功能測試,還可以用來做selenium/appnium等自動化測試、接口自動化測試,需要的朋友可以參考下2023-07-07
Python中g(shù)etattr函數(shù)和hasattr函數(shù)作用詳解
這篇文章主要介紹了Python中g(shù)etattr函數(shù)和hasattr函數(shù)作用的相關(guān)知識,非常不錯具有參考借鑒價值,需要的朋友可以參考下2016-06-06

