今天打包一个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

问题已找到,修改即可

StreamExecutionEnvironmentenv=StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(newConfiguration());

错了,改为:

StreamExecutionEnvironmentenv=StreamExecutionEnvironment.getExecutionEnvironment();

【经验总结】

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