今天打包一个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();
【经验总结】
要学会看日志,能解决很多低级问题