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

FLINK Could not get job jar and dependencies from JAR file: JAR file does not exist:

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

FLINK Could not get job jar and dependencies from JAR file: JAR file does not exist:

问题背景:使用flink客户端执行flink提交到yarn上,输入参数-yjm等调整flink参数,执行后出现下面问题

/data/flink/flink-1.13.2/bin/flink run -yjm 4096m -ytm 4096m  -ynm test13  -yd -m yarn-cluster   -yqu test  -C https://files.huizecdn.com/file2/M00/00/01/rBMBfmGSRQqAAIQSAAAKEcKAWyg678.jar -c com.huize.beidou.realtime.streaming.core.JobApplication /home/it/flink/core/flink-streaming-core.jar -sql /home/it/flink/sql/job_sql_4.sql  -type 0
Setting HADOOP_CONF_DIR=/etc/hadoop/conf because no HADOOP_CONF_DIR or HADOOP_CLASSPATH was set.
Setting Hbase_CONF_DIR=/etc/hbase/conf because no Hbase_CONF_DIR was set.
Could not get job jar and dependencies from JAR file: JAR file does not exist: -yjm

Could not get job jar and dependencies from JAR file: JAR file does not exist: -yjm

这是由于Flink on YARN 客户端通常需配置HADOOP_ CLASSPATH 环境变量来让客户端能加载到 Hadoop 配置和依赖 JAR 文件

解决方案,在flink脚本中添加环境变量,flink客户端bin目录如下

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

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

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