我怀疑是JM没有把flink-conf.yaml注册为local resource,最根本的原因应该还是你的提交方式 有问题,导致有些文件没有ship过去。如果你可以把JM的log以及launch_container.sh脚本发出来, 应该可以看出来原因
Best, Yang Leonard Xu <[email protected]> 于2020年6月1日周一 上午9:39写道: > 邮件里的图片经常看不到,可以用图床工具,放链接。 > > > 在 2020年6月1日,09:27,[email protected] 写道: > > > > > > 这个邮件好像图片都看不到啊,你们能看到不? > > > > > > > > 发件人: 程龙 > > 发送时间: 2020-05-30 19:20 > > 收件人: user-zh > > 主题: Re:re:提交flink代码 无法创建taskmanager flink web界面一致停留在created状态 ,日志报错如下 > > > > > > 是用代码提交的jobmanager 是可以加载的 就是启动taskmanager 这个目录就没有创建, 界面如下 ,错误日志就是我下面贴出来的那个 > > > > > > > > > > 在 2020-05-30 19:16:57,"462329521" <[email protected]> 写道: > >> 你的提交命令是什么呢 看样子是加载不到配置文件 > >> > >> > >> ------------------ 原始邮件 ------------------ > >> 发件人: "程龙"<[email protected]>; > >> 发件时间: 2020-05-30 19:13 > >> 收件人: "user-zh"<[email protected]>; > >> 主题: 提交flink代码 无法创建taskmanager flink web界面一致停留在created状态 ,日志报错如下 > >> > >> > >> > >> 2020-05-30 19:07:31,418 INFO > org.apache.flink.yarn.YarnTaskExecutorRunner - > -------------------------------------------------------------------------------- > 2020-05-30 19:07:31,418 INFO org.apache.flink.yarn.YarnTaskExecutorRunner > - Registered UNIX signal handlers for [TERM, HUP, INT] > 2020-05-30 19:07:31,420 INFO org.apache.flink.yarn.YarnTaskExecutorRunner > - Current working Directory: > /tmp/hadoop-bjhl/nm-local-dir/usercache/bjhl/appcache/application_1590820026922_0020/container_1590820026922_0020_01_000008 > 2020-05-30 19:07:31,427 ERROR org.apache.flink.yarn.YarnTaskExecutorRunner > - YARN TaskManager initialization failed. > org.apache.flink.configuration.IllegalConfigurationException: The Flink > config file > '/tmp/hadoop-bjhl/nm-local-dir/usercache/bjhl/appcache/application_1590820026922_0020/container_1590820026922_0020_01_000008/flink-conf.yaml' > (/tmp/hadoop-bjhl/nm-local-dir/usercache/bjhl/appcache/application_1590820026922_0020/container_1590820026922_0020_01_000008) > does not exist. at > org.apache.flink.configuration.GlobalConfiguration.loadConfiguration(GlobalConfiguration.java:112) > at > org.apache.flink.yarn.YarnTaskExecutorRunner.run(YarnTaskExecutorRunner.java:114) > at > org.apache.flink.yarn.YarnTaskExecutorRunner.main(YarnTaskExecutorRunner.java:82) > > > > > > > > > > > >
