您的位置:首页 > 科技 > 能源 > 小程序开发网站设计制作_口碑营销的策略技巧_seo矩阵培训_seo教育

小程序开发网站设计制作_口碑营销的策略技巧_seo矩阵培训_seo教育

2024/12/23 7:56:02 来源:https://blog.csdn.net/weixin_52642840/article/details/143463698  浏览:    关键词:小程序开发网站设计制作_口碑营销的策略技巧_seo矩阵培训_seo教育
小程序开发网站设计制作_口碑营销的策略技巧_seo矩阵培训_seo教育

前提

配置好了hadoop集群,均有python环境

python环境的配置和spark软件的下载

spark-本地模式的配置和简单使用-CSDN博客

环境配置 

1、上传,解压,重命名
tar -zxvf /opt/install/spark-3.1.2-bin-hadoop3.2.tgz -C /opt/modules
mv spark-3.1.2-bin-hadoop3.2/ spark-yarn
2、删除之前本地模式下的软连接
rm -rf spark 
3、建立yarn模式下的软连接
ln -s spark-yarn spark
4、配置环境变量
export SPARK_HOME=/opt/installs/spark
export PATH=$PATH:$SPARK_HOME/bin
5、刷新
source /etc/profile
6、上传spark jar包:
hdfs dfs -mkdir -p /spark/jars/
hdfs dfs -put /opt/installs/spark/jars/* /spark/jars/
7、创建目录 必须创建 否则不能运行程序
hdfs dfs -mkdir /spark/eventLogs

修改配置文件

spark-env.sh

mv spark-env.sh.template spark-env.sh#    设置JAVA安装目录、HADOOP和YARN配置文件目录export JAVA_HOME=/opt/installs/jdk
export HADOOP_CONF_DIR=/opt/installs/hadoop/etc/hadoop
export YARN_CONF_DIR=/opt/installs/hadoop/etc/hadoop
## 历史日志服务器
export SPARK_DAEMON_MEMORY=1g
export SPARK_HISTORY_OPTS="-Dspark.history.fs.logDirectory=hdfs://bigdata01:9820/spark/eventLogs/ -Dspark.history.fs.cleaner.enabled=true"

spark-defaults.conf

mv spark-defaults.conf.template spark-defaults.conf## 添加内容:
spark.eventLog.enabled           true
spark.eventLog.dir           hdfs://bigdata01:9820/spark/eventLogs
spark.eventLog.compress           true
spark.yarn.historyServer.address bigdata01:18080
spark.yarn.jars           hdfs://bigdata01:9820/spark/jars/*

log4j.properties

mv log4j.properties.template log4j.properties# 修改级别为WARN,打印日志少一点。

 yarn-site.xml————hadoop中

"""
正常来说spark的配置是不含yarn的,
因为spark在yarn的基础上运行,
不是yarn依赖spark 
看看
"""# 检查以下内置少什么,就配什么。
<property><name>yarn.log-aggregation-enable</name><value>true</value>
</property><!-- 历史日志在HDFS保存的时间,单位是秒 -->
<!-- 默认的是-1,表示永久保存 -->
<property><name>yarn.log-aggregation.retain-seconds</name><value>604800</value>
</property><property><name>yarn.log.server.url</name><value>http://bigdata01:19888/jobhistory/logs</value>
</property><!-- 关闭yarn内存检查 -->
<property><name>yarn.nodemanager.pmem-check-enabled</name><value>false</value>
</property>
<property><name>yarn.nodemanager.vmem-check-enabled</name><value>false</value>
</property>

分发文件

将spark,和修改过的yarn-site.xml,还有创建的软链接分发一下

启动

启动hadoop集群

start-all.sh

启动日志服务

 # 启动MR的JobHistoryServer:19888mapred --daemon start historyserver# 启动Spark的HistoryServer:18080/opt/installs/spark/sbin/start-history-server.sh

使用一下

/opt/installs/spark/bin/spark-submit --master yarn /opt/installs/spark/examples/src/main/python/pi.py 100

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com