Docker 搭建 Spark

2022-04-01 16:34:28 浏览数 (1)

引言

使用 Dockerfile、Docker Compose 构建 Spark集群环境,方便以后的部署,日常开发。

Spark部署模式主要有四种:

  1. Local模式(单机模式)
  2. Standalone模式(使用Spark自带的简单集群管理器)
  3. YARN模式(使用YARN作为集群管理器)
  4. Mesos模式(使用Mesos作为集群管理器)

关联仓库地址:https://github.com/yiyungent/spark-docker

1. 准备

代码语言:javascript复制
FROM ubuntu:20.04 AS base

LABEL maintainer="yiyun <yiyungent@gmail.com>"

# 设置国内阿里云镜像源
COPY etc/apt/aliyun-ubuntu-20.04-focal-sources.list   /etc/apt/sources.list

# 时区设置
ENV TZ=Asia/Shanghai

RUN apt-get update

# 1. 安装常用软件
RUN apt-get install -y wget
RUN apt-get install -y ssh
RUN apt-get install -y vim

2. 安装 Java

代码语言:javascript复制
# 2. 安装 Java
ADD jdk-8u131-linux-x64.tar.gz /opt/
RUN mv /opt/jdk1.8.0_131 /opt/jdk1.8
ENV JAVA_HOME=/opt/jdk1.8
ENV JRE_HOME=${JAVA_HOME}/jre
ENV CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib
ENV PATH=${JAVA_HOME}/bin:$PATH

测试

代码语言:javascript复制
docker build -t spark-with-java .
代码语言:javascript复制
docker run -it --name spark-container spark-with-java bash

3. 安装 Scala

代码语言:javascript复制
# 3. 安装 Scala
RUN wget http://downloads.lightbend.com/scala/2.12.1/scala-2.12.1.tgz
RUN mkdir /opt/scala
RUN tar -zxvf scala-2.12.1.tgz -C /opt/scala/
ENV SCALA_HOME=/opt/scala/scala-2.12.1 
ENV PATH=${SCALA_HOME}/bin:$PATH 

测试

代码语言:javascript复制
docker build -t spark-with-scala .
代码语言:javascript复制
docker run -it --name spark-container spark-with-scala bash
代码语言:javascript复制
scala -version

4. 安装 Spark

代码语言:javascript复制
# 4. 安装 Spark
RUN mkdir /opt/spark 
#RUN wget https://downloads.apache.org/spark/spark-3.0.2/spark-3.0.2-bin-hadoop2.7.tgz
RUN wget https://mirrors.tuna.tsinghua.edu.cn/apache/spark/spark-3.0.2/spark-3.0.2-bin-hadoop2.7.tgz
RUN tar -zxvf spark-3.0.2-bin-hadoop2.7.tgz -C /opt/spark/
ENV SPARK_HOME=/opt/spark/spark-3.0.2-bin-hadoop2.7
ENV PATH=${SPARK_HOME}/bin:$PATH

注意: 这里使用的是 spark-3.0.2-bin-hadoop2.7 ,此包已经包含了编译好的hadoop2.7, start-all.sh 将同时启动 Hadoop 集群

测试

代码语言:javascript复制
docker build -t spark .
代码语言:javascript复制
docker run -it --name spark-container spark bash
代码语言:javascript复制
spark-shell
代码语言:javascript复制
3 5

补充:

使用如下命令退出spark-shell交互式环境:

代码语言:javascript复制
:quit

测试Spark是否可以正常访问Ubuntu系统中的本地文件

代码语言:javascript复制
vim /home/word.txt
代码语言:javascript复制
I love Spark
I love Hadoop
Spark is good
代码语言:javascript复制
spark-shell
代码语言:javascript复制
val line=sc.textFile("file:///home/word.txt")
代码语言:javascript复制
println(line.count())

测试Spark是否能够正常访问Hadoop中的HDFS

由于我们经常需要让Spark去访问Hadoop中的HDFS, 因此,需要测试一下Spark是否可以正常访问HDFS。 执行如下命令启动Hadoop中的HDFS:

启动 Spark 集群

默认在哪台机器启动,那台机器就是master节点

代码语言:javascript复制
/opt/spark/spark-3.0.2-bin-hadoop2.7/sbin/start-all.sh

补充:

也可以利用环境变量:

代码语言:javascript复制
$SPARK_HOME/sbin/start-all.sh

补充:

也可以在其它节点启动备份主节点:

代码语言:javascript复制
$SPARK_HOME/sbin/start-master.sh

测试

参考:

  • Data Exploration Using Spark

参考

感谢帮助!

  • 利用docker搭建spark测试集群 - 知乎
  • 马踏飞燕——奔跑在Docker上的Spark - jasonfreak - 博客园
  • Spark安装和使用_厦大数据库实验室博客
  • 在集群上运行Spark应用程序_厦大数据库实验室博客
  • 马踏飞燕——奔跑在Docker上的Spark - jasonfreak - 博客园
  • 阿里云中搭建大数据实验环境_厦大数据库实验室博客
  • Ubuntu 14.04 Spark单机环境搭建与初步学 - 知乎

本文作者: yiyun

本文链接: https://moeci.com/posts/分类-docker/docker-spark/

版权声明: 本博客所有文章除特别声明外,均采用 BY-NC-SA 许可协议。转载请注明出处!

0 人点赞