博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Spark分布式集群的搭建和运行
阅读量:6717 次
发布时间:2019-06-25

本文共 1489 字,大约阅读时间需要 4 分钟。

集群共三台CentOS虚拟机,一个Matser,主机名为master;三个Worker,主机名分别为master、slave03、slave04。前提是Hadoop和Zookeeper已经安装并且开始运行。

1. 在master上下载Scala-2.11.0.tgz,复制到/opt/下面,解压,在/etc/profile加上语句:

export SCALA_HOME=/opt/scala-2.11.0export PATH=$PATH:$SCALA_HOME/bin

然后运行命令:

source /etc/profile

在slave03、slave04上也执行相同的操作。

2. 在master上下载spark-2.1.0-bin-hadoop2.6,复制到/opt/下面。解压,在/etc/profile加上语句:

export SPARK_HOME=/opt/spark-2.1.0-bin-hadoop2.6export PATH=$PATH:$SPARK_HOME/bin:$SPARK_HOME/sbin

然后运行命令:

source /etc/profile

3. 编辑${SPARK_HOME}/conf/spark-env.sh文件,增加下面的语句:

# JAVA_HOMEexport JAVA_HOME=/opt/jdk1.8.0_121# SCALA_HOMEexport SCALA_HOME=/opt/scala-2.11.0# SPARK_HOMEexport SPARK_HOME=/opt/spark-2.1.0-bin-hadoop2.6# Master主机名export SPARK_MASTER_HOST=master# Worker的内存大小export SPARK_WORKER_MEMORY=1g# Worker的Cores数量export SPARK_WORKER_CORES=1# SPARK_PID路径export SPARK_PID_DIR=$SPARK_HOME/tmp# Hadoop配置文件路径export HADOOP_CONF_DIR=/opt/hadoop-2.6.0-cdh5.9.0/etc/hadoop# Spark的Recovery Mode、Zookeeper URL和路径export SPARK_DAEMON_JAVA_OPTS="-Dspark.deploy.recoveryMode=ZOOKEEPER -Dspark.deploy.zookeeper.url=master:12181,slave03:12181,slave04:12181 -Dspark.deploy.zookeeper.dir=/spark"

在${SPARK_HOME}/conf/slaves中增加:

matserslave03slave04

这样就设置了三个Worker。

修改文件结束以后,将${SPARK_HOME}用scp复制到slave03和slave04。

4. 在master上进入${SPARK_HOME}/sbin路径,运行:

./start-master.sh

这是启动Master。

再运行:

./start-slaves.sh

这是启动Worker。

5. 在master上运行jps,如果有Master和Worker表明启动成功:

在slave03、slave04上运行jps,有Worker表明启动成功:

6. 访问http://master:8081,出现下面的页面表明启动成功:

转载地址:http://ozumo.baihongyu.com/

你可能感兴趣的文章
我的友情链接
查看>>
linux开机启动jar
查看>>
重构:改善既有代码的设计 精彩书评二
查看>>
框架与CSRF防御
查看>>
Eclipse汉化
查看>>
MongoDB入门
查看>>
linux操作界面配置
查看>>
命名管道操作
查看>>
Linux下的磁盘使用情况
查看>>
python基础 -- acm
查看>>
android第一天
查看>>
湖南卫视邮件服务器架设方案
查看>>
LoadRunner11破解详解
查看>>
排序算法 时间、空间复杂度
查看>>
集合框架(集合的继承体系图解)
查看>>
Win32应用程序(SDK)设计原理详解
查看>>
windows serve 2012部署操作系统之部署前期准备(九)
查看>>
JFinal整合HTTL模板引擎
查看>>
“Object "netns" is unknown, try "ip help".\n'”报错
查看>>
SQL语句中----删除表数据drop、truncate和delete的用法
查看>>