下面按**“从零在 Linux 上搭建 Spark 集群”的思路,给你一个清晰、可操作的步骤说明**(以 Spark Standalone 集群为例,最常用、最适合学习)。
示例:
master: 192.168.1.10
worker1: 192.168.1.11
worker2: 192.168.1.12
java -version
如果没有:
sudo apt install openjdk-8-jdk # Ubuntu
# 或
sudo yum install java-1.8.0-openjdk
配置环境变量:
export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64
每台机器:
sudo vim /etc/hosts
添加:
192.168.1.10 master
192.168.1.11 worker1
192.168.1.12 worker2
在 Master 上:
ssh-keygen -t rsa
ssh-copy-id worker1
ssh-copy-id worker2
wget https://archive.apache.org/dist/spark/spark-3.4.1/spark-3.4.1-bin-hadoop3.tgz
tar -zxvf spark-3.4.1-bin-hadoop3.tgz
mv spark-3.4.1-bin-hadoop3 /opt/spark
vim ~/.bashrc
export SPARK_HOME=/opt/spark
export PATH=$SPARK_HOME/bin:$PATH
source ~/.bashrc
spark-env.shcd $SPARK_HOME/conf
cp spark-env.sh.template spark-env.sh
vim spark-env.sh
添加:
export JAVA_HOME=/usr/lib/jvm/java-8-openjdk-amd64
export SPARK_MASTER_HOST=master
export SPARK_MASTER_PORT=7077
workers(旧版叫 slaves)cp workers.template workers
vim workers
内容:
worker1
worker2
$SPARK_HOME/sbin/start-all.sh
jps
# Master
jps
# Worker
浏览器访问:
http://master:8080
可看到 Worker 节点信息。
spark-submit \
--master spark://master:7077 \
--class org.apache.spark.examples.SparkPi \
$SPARK_HOME/examples/jars/spark-examples_2.12-3.4.1.jar \
100
$SPARK_HOME/sbin/stop-all.sh
✅ 防火墙关闭
systemctl stop firewalld
✅ 时间同步
ntpdate cn.pool.ntp.org
✅ Worker 连不上 Master
我也可以帮你:
直接告诉我你的 Linux 版本和使用场景即可。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。