亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

Python搭建Spark分布式集群環(huán)境

系統(tǒng) 2433 0

前言

Apache Spark 是一個新興的大數(shù)據(jù)處理通用引擎,提供了分布式的內存抽象。Spark 最大的特點就是快,可比 Hadoop MapReduce 的處理速度快 100 倍。本文沒有使用一臺電腦上構建多個虛擬機的方法來模擬集群,而是使用三臺電腦來搭建一個小型分布式集群環(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官方下載地址,按照如下圖下載。

Python搭建Spark分布式集群環(huán)境_第1張圖片

下載完成后,執(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文件設置Worker節(jié)點。編輯slaves內容,把默認內容localhost替換成如下內容:

            
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,添加如下內容:

            
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文件夾復制到各個節(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,如下圖:

Python搭建Spark分布式集群環(huán)境_第2張圖片

關閉Spark集群

1.關閉Master節(jié)點

            
sbin/stop-master.sh
          

2.關閉Worker節(jié)點

            
sbin/stop-slaves.sh
          

3.關閉Hadoop集群

            
cd /usr/local/hadoop/
sbin/stop-all.sh
          

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。


更多文章、技術交流、商務合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯(lián)系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦!!!

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 中国国产成人精品久久 | 国产成人精品亚洲77美色 | 最新地址四虎www4hutv | 免费看操片 | 女人18一级毛片免费观看 | 哪里有毛片 | 国产综合久久久久久鬼色 | 黄页在线免费观看 | 可以免费观看欧美一级毛片 | 欧美在线中文 | 久久一本精品 | 日本不卡中文字幕一区二区 | 97se亚洲国产综合自在线观看 | 一级毛片日本特黄97人人 | 青草精品视频 | 色香欲综合网 | 91在线播 | 免费视频不卡一区二区三区 | 天天干天天操天天透 | 欧美特黄一级大黄录像 | 免费爱爱视频网站 | 狠狠色狠狠色88综合日日91 | 亚洲精品中文字幕乱码一区二区 | 四虎影视久久久免费 | 午夜视频网站 | 欧美午夜寂寞影院安卓列表 | 欧美一区二区三区久久久人妖 | 亚洲欧美日韩激情在线观看 | 激情五月综合综合久久69 | 色费女人18毛片a级视频在线 | 四虎永久网站 | 农村寡妇一级毛片免费看视频 | 亚洲视频国产精品 | 日韩美在线 | 精品视频在线免费播放 | 国产在线视频资源 | 中文字幕一区二区三区精彩视频 | 伊人久久精品亚洲精品一区 | 国产成人久久精品推最新 | 91精品91久久久久久 | 亚洲欧美日韩另类 |