栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Python

pySpark启动与执行例子

Python 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

pySpark启动与执行例子

启动spark

注:必须先启动Hadoop,但只启动hdfs即可,不用start-all,使用start-dfs.sh即可

检查

jps

在Master节点上出现了NameNode、ResourceManager、SecondaryNameNode;

在主节点启动:

cd /usr/data2/program/spark/spark/sbin/

./start-all.sh

检查

jps

在Master节点上出现了Master;

在工作节点出现了Worker

启动pyspark

注:必须先启动spark

在主节点机执行即可

在 ./spark/bin目录下,启动pyspark

或者直接执行pyspark (因为配置了环境变量)

进入python模式下的spark

报错:

pyspark依赖python环境,ubuntu自带的python是2.7

要先安装python3,可参考python文章,安装miniconda

创建pyspark的独立python环境

所有节点机都要配置

使用conda就很好创建

克隆一个spark独立python环境

(base) root@pc2-node2:~# conda info -e

# conda environments:

#

base                  *  /usr/data2/program/conda/miniconda3

spark                    /usr/data2/program/conda/miniconda3/envs/spark

克隆完毕后,

/usr/data2/program/conda/miniconda3/envs/spark/bin/python

这个就是spark专用的环境的python路径

配置spark的python环境

所有节点机都要配置

cd /usr/data2/program/spark/spark/conf/

vi spark-env.sh

增加

export PYSPARK_PYTHON=/usr/data2/program/conda/miniconda3/envs/spark/bin/python

重启spark、

重新进入pyspark

主节点机执行

./stop-all.sh

./start-all.sh

然后执行pyspark进入

这样就是成功进入pyspark了

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/932528.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号