Spark集群试运行

太过爱你忘了你带给我的痛 2024-02-19 15:47 41阅读 0赞

### Spark集群试运行 ###

下面试运行Spark。  
**1）在Master主机上，分别启动Hadoop与Spark。**

cd /usr/local/hadoop/sbin/./start-all.shcd /usr/local/spark/sbin./start-all.sh

\*\*2）检查Master与Worker进程是否在各自节点上启动。在Master主机上，执行命令jps，\*\*如图1-5所示。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNjg4NDcy_size_16_color_FFFFFF_t_70]

图1-5 在Master主机上执行jps命令  
在Worker节点上，以Worker1为  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNjg4NDcy_size_16_color_FFFFFF_t_70 1]  
执行命令jps，如图1-6所示。

图1-6 在Worker节点上执行jps命令  
从图1-6中可以清晰地看到，Master进程与Worker及相关进程在各自节点上成功运行，Hadoop与Spark运行正常。  
**3）通过Spark Web UI查看集群状态。在浏览器中输入Master的IP与端口，打开Spark Web UI**，如图1-7所示。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNjg4NDcy_size_16_color_FFFFFF_t_70 2]

**Spark Web UI界面**  
从图1-7中可以看到，当集群内仅有一个Worker节点时，Spark Web UI显示该节点处于Alive状态，CPU Cores为1，内存为1GB。此页面会列出集群中所有启动后的Worker节点及应用的信息。  
**4）运行样例。Spark自带了一些样例程序可供试运行。在Spark根目录下**，example/src/main文件夹中存放着Scala、Java、Python及用R语言编写的样例，  
用户可以运行其中的某个样例程序。  
先拷贝到Spark根目录下，然后执行bin/run-example \[class\] \[params\]即可。  
例如可以在Master主机命令行执行：  
./run-example SparkPi 10  
然后可以看到该应用的输出，在Spark Web UI上也可以查看应用的状态及其他信息。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNjg4NDcy_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/dec64fe228fb4ac18dadd07333056ba6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNjg4NDcy_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/78ff96cb08e8404c87e91b1ffb1d1284.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQzNjg4NDcy_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/b06f26ba741a48559c7d1c8e9bc70d51.png