Flink提交jar出现错误RestHandlerException: No jobs included in application.

发布于:2023-09-08 ⋅ 阅读:(77) ⋅ 点赞:(0)

今天打包一个flink的maven工程为jar,通过flink webUI提交,发现居然报错。

如上图所示,提示错误为:

Server Response Message:

org.apache.flink.runtime.rest.handler.RestHandlerException: No jobs included in application. at

【解决方案】

查看 

JOB Manager日志

发现是环境问题,再仔细看 ,居然使用了

StreamExecutionEnvironment.createLocalEnvironmentWithWebUI

问题已找到,修改即可

        StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration());

错了,改为:

        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

【经验总结】

要学会看日志,能解决很多低级问题


网站公告

今日签到

点亮在社区的每一天
去签到