Re: Flink 1.10.0 on yarn 提交job失败

2020-12-15 文章 Xintong Song
看起来是 Yarn 没有给应用设置 hadoop classpath。可以登机器确认一下 launch_container.sh 的内容,container 启动命令里是否包含了正确的 hadoop classpath。Yarn 是定制过的版本吗?按理说开源版本都会给 container 设置 hadoop classpath 的。 1.10 版本以前可以运行是因为 flink 自带了 shaded hadoop,从 1.10 版本开始 flink 默认不再携带 shaded hadoop,而是使用集群环境的 hadoop 依赖。你也可以自己携带 shaded

Flink 1.10.0 on yarn 提交job失败

2020-12-12 文章 Jacob
Hello, 请问在flink 1.10.0 on yarn提交job出现此问题是什么原因,hadoop jar包依赖吗?该程序在1.10以下的版本均可运行,在1.10.0无法提交。 谢谢! [jacob@hadoop001 bin]$ ./yarn logs -applicationId application_1603495749855_57650 20/12/11 18:52:55 INFO client.RMProxy: Connecting to