提示:本文仅适用于本人作业和部分新手所使用,如果本文有不适之处,敬请改正,感谢。

文章目录


一、搭建集群

(一)私有云上创建三台虚拟机

  1. 创建虚拟机的过程,这里就不再继续进行赘述,没有创建虚拟机的请先按照此篇博客《如何在OpenStack创建的私有云上搭建并配置虚拟机》把虚拟机搭建完毕后,再观看此篇博客
    在这里插入图片描述

  2. 进入win7虚拟机启动远程桌面,在本机使用“win+r”进入“运行程序”,然后再输入“mstsc”,单击确定按钮,进入远程桌面对话框
    在这里插入图片描述

  3. 进入远程桌面后,安装SecureCRT软件,下面会使用此软件进行操作

本次所有需要使用到的包(可以自行网络下载,也可以使用我的):
在这里插入图片描述

(二)利用SecureCRT软件分别登录三台虚拟机

1、如何连接虚拟机

  • 先打开软件,单击快速连接按钮,打开连接对话框,输入IP地址(192.168.9.xxx)和用户名(root),单击继续按钮

在这里插入图片描述

  • 输入密码,并勾选保存密码(后期就不用再重新输入密码了),然后单击OK,进入虚拟机

在这里插入图片描述

1.1、登录master虚拟机

在这里插入图片描述

1.2、登录slave1虚拟机

在这里插入图片描述

1.3、登录slave2虚拟机

在这里插入图片描述

2.为了使主机能够更加明容易识别出来,可以为相应的主机进行重命名

  • 单击“连接”按钮,进入连接对话框后,鼠标右键单击相应的IP地址,出现子菜单框后,单击“Rename”选项
    在这里插入图片描述
  • 在文本框里面输入需要的主机名(master、slave1、slave2)在这里插入图片描述

3.如果觉得本软件有点不美观还可以进入设置进行美化

  • 单击“option”按钮,进入设置在这里插入图片描述
  • 单击“Emulantion”按钮,再单击“Termina”l的下级菜单,选择“Linux
    在这里插入图片描述
  • 单击“Appearance”→“Current color schen”→“Font”→“Character encoding”按钮,分别选择合适的样式

在这里插入图片描述

  • 我们可以打开软件的“chat Windows”功能,这样只要输入一个命令,然后多个窗口都可以进行相同的输入,为我们减去了大量的重复操作

在这里插入图片描述
在这里插入图片描述

  • 分别给三台虚拟机安装vim编辑器

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  • 如果在这个地方无法连接外网进行下载的话,可以尝试对/etc/resolv.conf文件添加了域名解析服务器,再尝试重新进行下载
nameserver 8.8.8.8
nameserver 114.114.114.114
  • 执行命令:vim /etc/resolv.conf,修改/etc/resolv.conf文件

在这里插入图片描述

  • 添加两个域名解析服务器

在这里插入图片描述

  • 存盘退出

在这里插入图片描述

  • 再对实例进行测试能否访问外网
  • 输入 ping www.baidu.com
    在这里插入图片描述
  • 大功告成,现在已经能访问外网了

(三)查看三台虚拟机主机名

  • 查看master虚拟机的主机名

在这里插入图片描述

  • 查看slave1虚拟机的主机名

在这里插入图片描述

  • 查看slave2虚拟机的主机名

在这里插入图片描述

(四)配置三台虚拟机IP-主机名映射

192.168.9.103 master
192.168.9.104 slave1
192.168.9.105 slave2

1、配置master虚拟机IP-主机名映射

  • 执行命令:vim /etc/hosts

在这里插入图片描述

  • 键盘单击“O”键进行输入,输入映射

在这里插入图片描述

  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

2、配置slave1虚拟机IP-主机名映射

  • 执行命令:vim /etc/hosts

在这里插入图片描述

  • 键盘单击“O”键进行输入,输入映射

在这里插入图片描述

  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

3、配置slave2虚拟机IP-主机名映射

  • 执行命令:vim /etc/hosts

在这里插入图片描述

  • 键盘单击“O”键进行输入,输入映射

在这里插入图片描述

  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

(五)关闭与禁用防火墙

  • 关闭与禁用防火墙

systemctl stop firewalld.service # 关闭防火墙
systemctl disable firewalld.service # 禁用防火墙

  • 查看防火墙状态

systemctl status firewalld.service

1、关闭与禁用master虚拟机的防火墙

在这里插入图片描述

2、关闭与禁用slave1虚拟机的防火墙

在这里插入图片描述

3、关闭与禁用slave2虚拟机的防火墙

在这里插入图片描述

(六)关闭SeLinux安全机制

  • 需要对/etc/sysconfig/selinux文件里SELINUX=enforcing,将enforcing改成disable,就可以关闭SeLinux安全机制

1、在master虚拟机上关闭SeLinux安全机制

  • 执行命令:vim /etc/sysconfig/selinux
    在这里插入图片描述

  • 单击“A”键,并在相应位置输入disable,对文件进行修改
    在这里插入图片描述

  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

2、在slave1虚拟机上关闭SeLinux安全机制

  • 执行命令:vim /etc/sysconfig/selinux

在这里插入图片描述

  • 单击“A”键,并在相应位置输入disable,对文件进行修改

在这里插入图片描述

  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出
    在这里插入图片描述

3、在slave2虚拟机上关闭SeLinux安全机制

  • 执行命令:vim /etc/sysconfig/selinux

在这里插入图片描述

  • 单击“A”键,并在相应位置输入disable,对文件进行修改

在这里插入图片描述

  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

(七)设置三台虚拟机相互免密登录

1、master虚拟机免密登录master、slave1与slave2

  • 执行命令:ssh-keygen,生成密钥对
    在这里插入图片描述

  • 执行命令:ssh-copy-id root@master,将公钥拷贝到master

在这里插入图片描述

  • 执行命令:ssh-copy-id root@slave1,将公钥拷贝到slave1

在这里插入图片描述

  • 执行命令:ssh-copy-id root@slave2,将公钥拷贝到slave2

在这里插入图片描述

  • 验证master是否可以免密登录master、slave1与slave2

在这里插入图片描述

2、slave1虚拟机免密登录master、slave1与slave2

  • 执行命令:ssh-keygen,生成密钥对

在这里插入图片描述

  • 执行命令:ssh-copy-id root@master,将公钥拷贝到master

在这里插入图片描述

  • 执行命令:ssh-copy-id root@slave1,将公钥拷贝到slave1

在这里插入图片描述

  • 执行命令:ssh-copy-id root@slave2,将公钥拷贝到slave2

在这里插入图片描述

  • 验证slave1是否可以免密登录master、slave1与slave2

在这里插入图片描述

3、slave2虚拟机免密登录master、slave1与slave2

  • 执行命令:ssh-keygen,生成密钥对

在这里插入图片描述

  • 执行命令:ssh-copy-id root@master,将公钥拷贝到master

在这里插入图片描述

  • 执行命令:ssh-copy-id root@slave1,将公钥拷贝到slave1

在这里插入图片描述

  • 执行命令:ssh-copy-id root@slave2,将公钥拷贝到slave2

在这里插入图片描述

  • 验证slave2是否可以免密登录master、slave1与slave2

在这里插入图片描述

(八)在三台虚拟机上安装lrzsr

1、在master虚拟机上安装lrzsz

  • 执行命令:yum -y install lrzsz
    在这里插入图片描述

2、在slave1虚拟机上安装lrzsz

  • 执行命令:yum -y install lrzsz

在这里插入图片描述

3、在slave2虚拟机上安装lrzsz

  • 执行命令:yum -y install lrzsz

在这里插入图片描述

  • 装这个命令是因为待会儿我们会使用rz命令来上传压缩包到三台虚拟机

(九)在三台虚拟机上安装配置JDK

1、在master虚拟机上安装配置JDK

  • 上传下载到win7上面的Java安装包到master的/opt目录

在这里插入图片描述
在这里插入图片描述

  • 执行tar -zxvf jdk-8u231-linux-x64.tar.gz -C /usr/local,将Java安装包解压到/usr/local

在这里插入图片描述

  • 执行命令:ls /usr/local,查看解压之后的jdk

在这里插入图片描述

  • 执行命令:vim /etc/profile,配置环境变量
    在这里插入图片描述
  • 单击“O”键,对文件进行添加,在文件的尾巴上面加入相应的环境变量
    在这里插入图片描述
#JAVA_HOME
export JAVA_HOME=/usr/local/jdk1.8.0_231
export PATH=$PATH:$JAVA_HOME/bin
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

  • 执行命令:source /etc/profile,让配置生效

在这里插入图片描述

  • 查看JDK版本(java -version

在这里插入图片描述

2、将master虚拟机上安装的JDK以及环境配置文件分发到slave1虚拟机

  • 执行命令:scp -r $JAVA_HOME root@slave1:$JAVA_HOME (-r recursive - 递归)

在这里插入图片描述

  • 在slave1虚拟机上查看Java是否拷贝成功

在这里插入图片描述

  • 在master虚拟机上,执行命令:scp /etc/profile root@slave1:/etc/profile,将环境配置文件分发到slave1虚拟机

在这里插入图片描述

  • 在slave1虚拟机上,使用命令cat /etc/profile查看从master虚拟机拷贝过来的配置文件profile

在这里插入图片描述

  • 执行命令:source /etc/profile,让配置生效

在这里插入图片描述

  • 执行命令:java -version,查看JDK版本

在这里插入图片描述

3、将master虚拟机上安装的JDK以及环境配置文件分发到slave2虚拟机

  • 执行命令:scp -r $JAVA_HOME root@slave2:$JAVA_HOME (-r recursive - 递归)

在这里插入图片描述

  • 在slave2虚拟机上查看Java是否拷贝成功

在这里插入图片描述

  • 在master虚拟机上,执行命令:scp /etc/profile root@slave2:/etc/profile,将环境配置文件分发到slave2虚拟机

在这里插入图片描述

  • 在slave2虚拟机上,使用命令cat /etc/profile查看从master虚拟机拷贝过来的配置文件profile

在这里插入图片描述

  • 执行命令:source /etc/profile,让配置生效

在这里插入图片描述

  • 执行命令:java -version,查看JDK版本

在这里插入图片描述

二、配置完全分布式Hadoop

(一)在master虚拟机上安装配置hadoop

1、上传hadoop安装包到/opt目录

  • 利用rz命令上传hadoop-2.7.1.tar.gz

在这里插入图片描述

2、将hadoop安装包解压到指定位置

  • 执行命令:tar -zxvf hadoop-2.7.1.tar.gz -C /usr/local

在这里插入图片描述

  • 查看解压之后的hadoop目录(bin: 可执行文件;etc/hadoop: 配置目录;sbin: 启动关闭系统的命令)

在这里插入图片描述

3、配置hadoop环境变量

  • 执行命令:vim /etc/profile

在这里插入图片描述

#HADOOP_HOME
export HADOOP_HOME=/usr/local/hadoop-2.7.1
export PATH=$PATH:$HADOOP_HOHE/bin
export PATH=$PATH:$HADOOP_HOME/sbin
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出
    在这里插入图片描述
  • 执行命令:source /etc/profile,让配置生效

在这里插入图片描述

4、编辑hadoop环境配置文件 - hadoop-env.sh

  • 执行命令:cd $HADOOP_HOME/etc/hadoop,进入hadoop配置目录

在这里插入图片描述

  • 执行命令:vim hadoop-env.sh

在这里插入图片描述

export JAVA_HOME=/usr/local/jdk1.8.0_231 
export  HADOOP_HOME=/usr/local/hadoop-2.7.1
export HADOOP_CONF_DIR=${HADOOP_HOME}/etc/hadoop
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

  • 执行命令source hadoop-env.sh,让配置生效

在这里插入图片描述

  • 查看三个配置的三个环境变量

在这里插入图片描述

5、编辑核心配置文件 - core-site.xml

  • 执行命令:vim core-site.xml
    在这里插入图片描述
    在这里插入图片描述
<configuration>
    <!--用来指定hdfs的老大-->
    <property>
        <name>fs.defaultFS</name>
        <value>hdfs://master:9000</value>
    </property>
    <!--用来指定hadoop运行时产生文件的存放目录-->
    <property>
        <name>hadoop.tmp.dir</name>
        <value>/usr/local/hadoop-2.7.1/tmp</value>
    </property>    
</configuration>
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

  • 由于配置了IP地址主机名映射,因此可用hdfs://master:9000,否则必须用IP地址hdfs://192.168.1.103:9000

在这里插入图片描述

6、编辑HDFS配置文件 - hdfs-site.xml

  • 执行命令:vim hdfs-site.xml

在这里插入图片描述

<configuration>
    <property>
        <!--设置名称节点的目录-->
        <name>dfs.namenode.name.dir</name>
        <value>/usr/local/hadoop-2.7.1/tmp/namenode</value>
    </property>
    <property>
        <!--设置数据节点的目录-->
        <name>dfs.datanode.data.dir</name>
        <value>/usr/local/hadoop-2.7.1/tmp/disk1,/usr/local/hadoop-2.7.1/tmp/disk2</value>
    </property>
</configuration>
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

7、编辑MapReduce配置文件 - mapred-site.xml

  • 基于模板生成配置文件,执行命令:cp mapred-site.xml.template mapred-site.xml

在这里插入图片描述

  • 执行命令:vim mapred-site.xml

在这里插入图片描述

<configuration>
    <property>
        <!--配置MR资源调度框架YARN-->
        <name>mapreduce.framework.name</name>
        <value>yarn</value>
    </property>
</configuration>

  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

8、编辑yarn配置文件 - yarn-site.xml

  • 执行命令:vim yarn-site.xml

在这里插入图片描述

<configuration>
    <property>
        <!--配置资源管理器-->
        <name>yarn.resourcemanager.hostname</name>
        <value>master</value>
    </property>
    <property>
        <!--配置节点管理器-->
        <name>yarn.nodemanager.aux-services</name>
        <value>mapreduce_shuffle</value>
    </property>
</configuration>
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

  • 说明:在hadoop-3.0.0的配置中,yarn.nodemanager.aux-services项的默认值是“mapreduce.shuffle”,但如果在hadoop-2.7 中继续使用这个值,NodeManager 会启动失败。

9、编辑slaves文件(定名分)

  • 通过slaves文件定义从节点,有两个:slave1与slave2
  • 执行命令:vim slaves

在这里插入图片描述
在这里插入图片描述

slave1
slave2
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

(二)在slave1虚拟机上安装配置hadoop

1、将master虚拟机上的hadoop分发到slave1虚拟机

  • 执行命令:scp -r $HADOOP_HOME root@slave1:$HADOOP_HOME

在这里插入图片描述

2、将master虚拟机上环境配置文件分发到slave1虚拟机

  • 执行命令:scp /etc/profile root@slave1:/etc/profile

在这里插入图片描述

3、在slave1虚拟机上让环境配置生效

  • 切换到slave1虚拟机,执行命令:source /etc/profile

在这里插入图片描述

(三)在slave2虚拟机上安装配置hadoop

1、将master虚拟机上的hadoop分发到slave2虚拟机

  • 执行命令:scp -r $HADOOP_HOME root@slave2:$HADOOP_HOME

在这里插入图片描述

2、将master虚拟机上环境配置文件分发到slave2虚拟机

  • 执行命令:scp /etc/profile root@slave2:/etc/profile

在这里插入图片描述

3、在slave2虚拟机上让环境配置生效

  • 切换到slave2虚拟机,执行命令:source /etc/profile

在这里插入图片描述

(四)在master虚拟机上格式化名称节点

  • 在master虚拟机上,执行命令:hdfs namenode -format

在这里插入图片描述
在这里插入图片描述

  • 看到22/03/20 20:08:43 INFO common.Storage: Storage directory /usr/local/hadoop-2.7.1/tmp/namenode has been successfully formatted.,表明名称节点格式化成功。

(五)启动与关闭Hadoop集群

1、在master虚拟机上启动hadoop服务

  • 执行命令:start-dfs.sh,启动hdfs服务
    在这里插入图片描述
  • 一个名称节点(namenode)——老大,在master虚拟机上;两个数据节点(datanode)——小弟,在slave1与slave2虚拟机上。
  • 辅助名称节点(secondarynamenode)的地址是0.0.0.0,这是默认的,当然可以修改,可以在hdfs-site.xml文件里配置辅助名称节点

在这里插入图片描述
在这里插入图片描述

    <property>
        <!--设置辅助名称节点-->
        <name>dfs.namenode.secondary.http-address</name>
        <value>master:50090</value>
    </property>
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出
    在这里插入图片描述
  • 再次启动hdfs服务,先停止,再重新启动stop-dfs.sh

在这里插入图片描述

  • 执行命令:start-dfs.sh

在这里插入图片描述

  • 这样就是在master虚拟机(192.168.1.103)上启动辅助名称节点(secondarynamenode
  • 使用jps命令分别查看三台虚拟机的进程

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

  • 执行命令:start-yarn.sh,启动YARN服务

在这里插入图片描述

  • 启动了YARN守护进程;一个资源管理器(resourcemanager)在master虚拟机上,两个节点管理器(nodemanager)在slave1与slave2虚拟机上
  • 再次执行命令jps查看master虚拟机的进程,只有NameNodeSecondaryNameNodeResourceManager

在这里插入图片描述

  • 查看slave1和slave2上的进程,只有NodeManagerDataNode
    在这里插入图片描述
    在这里插入图片描述

2、查看hadoop集群的WebUI界面

  • 在hw_win7虚拟机浏览器访问http://master:50070

在这里插入图片描述

  • 如果不能通过主机名master加端口50070的方式,原因在于没有在hosts文件里IP与主机名的映射,现在可以访问http://192.168.1.103:50070
  • 修改hw_win7虚拟机上的C:\Windows\System32\drivers\etc\hosts文件
    在这里插入图片描述
192.168.9.102 Lee
192.168.9.103 master
192.168.9.104 slave1
192.168.9.105 slave2
  • 重启hadoop集群,就可以访问http://master:50070
    在这里插入图片描述
  • 查看数据节点信息

在这里插入图片描述

  • 点开【Utilities】下拉菜单,选择【Browse the file system】

在这里插入图片描述

  • 现在的hdfs上还没有任何东西

在这里插入图片描述

  • 尝试在HDFS上创建一个目录BigData,执行命令:hadoop fs -mkdir /BigData

在这里插入图片描述
在这里插入图片描述

3、停止hadoop服务

  • 在master虚拟机上执行命令:stop-all.sh(相当于同时执行了stop-dfs.shstop-yarn.sh

在这里插入图片描述

  • 提示:This script is Deprecated. Instead use stop-dfs.sh and stop-yarn.sh,说明stop-all.sh脚本已经被废弃掉了,让我们最好使用stop-dfs.shstop-yarn.sh

三、配置Spark Standalone模式的集群

(一)在master主节点上安装配置Spark

1、上传spark安装包到master虚拟机

  • 利用rz将hw_win7虚拟机上的spark安装包上传到master虚拟机/opt目录

在这里插入图片描述

在这里插入图片描述

2、将spark安装包解压到master虚拟机指定目录

  • 执行命令:tar -zxvf spark-2.4.4-bin-hadoop2.7.tgz -C /usr/local

在这里插入图片描述

3、配置spark环境变量

  • 执行命令:vim /etc/profile

在这里插入图片描述

  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

  • 执行命令:source /etc/profile,让配置生效

在这里插入图片描述

  • 使用ll $SPARK_HOME命令查看spark安装目录(bin、sbin和conf三个目录很重要)

在这里插入图片描述

4、编辑spark环境配置文件 - spark-env.sh

  • 使用cd $SPARK_HOME/conf命令进入spark配置目录后,执行命令:cp spark-env.sh.template spark-env.shvim spark-env.sh

在这里插入图片描述
在这里插入图片描述

export JAVA_HOME=/usr/local/jdk1.8.0_231
export SPARK_MASTER_HOST=master
export SPARK_MASTER_PORT=7077
  • JAVA_HOME:指定JAVA_HOME的路径。若集群中每个节点在/etc/profile文件中都配置了JAVA_HOME,则该选项可以省略,Spark集群启动时会自动读取。为了防止出错,建议此处将该选项配置上。
  • SPARK_MASTER_HOST:指定集群主节点(Master)的主机名,此处为master。
  • SPARK_MASTER_PORT:指定Master节点的访问端口,默认为7077。
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

  • 执行命令:source spark-env.sh,让配置生效

在这里插入图片描述

5、创建slaves文件,添加从节点

  • 执行命令:vim slaves

在这里插入图片描述

  • 添加两个从节点的主机名

在这里插入图片描述

slave1
slave2
  • 单击“ESC”键退出输入模式,然后输入“:wq!”进行存盘退出

在这里插入图片描述

(二)在slave1从节点上安装配置Spark

1、把master虚拟机上的spark安装目录分发给slave1虚拟机

  • 执行命令:scp -r $SPARK_HOME root@slave1:$SPARK_HOME

在这里插入图片描述

2、将master虚拟机上环境变量配置文件分发到slave1虚拟机

  • 在master虚拟机上,执行命令:scp /etc/profile root@slave1:/etc/profile

在这里插入图片描述

  • 在slave1虚拟机上,执行命令:source /etc/profile

在这里插入图片描述

3、在slave1虚拟机上让spark环境配置文件生效

  • 使用cd $SPARK_HOME/conf命令进入spark配置目录后,再执行命令:source spark-env.sh

在这里插入图片描述

(三)在slave2从节点上安装配置Spark

1、把master虚拟机上的spark安装目录分发给slave2虚拟机

  • 执行命令:scp -r $SPARK_HOME root@slave2:$SPARK_HOME

在这里插入图片描述

2、将master虚拟机上环境变量配置文件分发到slave2虚拟机

  • 在master虚拟机上,执行命令:scp /etc/profile root@slave2:/etc/profile

在这里插入图片描述

  • 在slave2虚拟机上,执行命令:source /etc/profile

在这里插入图片描述

3、在slave2虚拟机上让spark环境配置文件生效

  • 使用cd $SPARK_HOME/conf命令进入spark配置目录后,再执行命令:source spark-env.sh

在这里插入图片描述

四、启动并使用Spark Standalone模式的集群

  • Spark standalone模式下使用的是Spark自带的资源调度框架,但是一般我们把数据保存在HDFS上,也就是用HDFS做数据的持久化,所以hadoop还是需要配置,但是可以只配置HDFS相关的,而Hadoop YARN不需要配置。启动Spark Standalone模式的集群,不需要启动YARN服务,因为Spark会使用自带的资源调度框架。

(一)启动hadoop的dfs服务

  • 在master虚拟机上执行命令:start-dfs.sh

在这里插入图片描述

(二)启动Spark集群

  • 在master虚拟机上使用 cd $SPARK_HOME/sbin命令进入spark安装目录下的sbin子目录,执行命令:./start-all.sh

在这里插入图片描述

  • 查看start-all.sh的源码,其中有以下两条命令:
# Start Master
"${SPARK_HOME}/sbin"/start-master.sh
# Start Worker
s"${SPARK_HOME}/sbin"/start-slaves.sh
  • 可以看到,当执行start-all.sh命令时,会分别执行start-master.sh命令启动Master,执行start-slaves.sh命令启动Worker。

  • 注意,若spark-evn.sh中配置了SPARK_MASTER_HOST属性,则必须在该属性指定的主机上启动Spark集群,否则会启动不成功;若没有配置SPARK_MASTER_HOST属性,则可以在任意节点上启动Spark集群,当前执行启动命令的节点即为Master节点。

  • 启动完毕后,分别在各节点执行jps命令,查看启动的Java进程。若在master节点存在Master进程,slave1节点存在Worker进程,slave2节点存在Worker进程,则说明集群启动成功。

  • 查看master节点进程

在这里插入图片描述

  • 查看slave1节点进程

在这里插入图片描述

  • 查看slave2节点进程

在这里插入图片描述

(三)访问Spark的WebUI

  • 在Lee_win7虚拟机上,访问http://master:8080

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

(四)启动Scala版Spark Shell

  • 执行命令:spark-shell --master spark://master:7077

在这里插入图片描述

  • 在/opt目录里执行命令:vim test.txt,并在该文件内随便添加几行内容

在这里插入图片描述

  • 在HDFS上创建park目录,将test.txt上传到HDFS的/park目录
hadoop fs -mkdir /park
hadoop fs -put /opt/test.txt /park

在这里插入图片描述

  • 使用hadoop fs -ls /park 查看该文件

在这里插入图片描述

  • 在其它虚拟机上也可以查看到该文件

在这里插入图片描述
在这里插入图片描述

  • 读取HDFS上的文件,创建RDD
val rdd = sc.textFile("/park/test.txt")

![(https://img-blog.csdnimg.cn/999b5ae692334f07aebb586017959756.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA54Ot5b-D5biC5rCR5bCP5p2O5ZCM5a2m,size_20,color_FFFFFF,t_70,g_se,x_16)

  • 查看第一行内容

在这里插入图片描述

(五)关闭Spark服务

  • 在master节点执行命令:stop-master.shstop-slaves.sh
    在这里插入图片描述

本文部分内容引用于华老师,如果有看不懂的地方可以去老师的博客下面查找相应的办法,原文链接:http://t.csdn.cn/rkZgL


Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐