是不是没有执行操作啊。例如print、collect等方法 --------------原始邮件-------------- 发件人:"guanyq "<dlgua...@163.com>; 发送时间:2020年4月16日(星期四) 上午8:03 收件人:"user-zh" <user-zh@flink.apache.org>; 主题:flink1.9,后台提交job失败 -----------------------------------
代码里面是有env.execute,提交job出现以下错误,可能时什么原因? The program didn't contain a Flink job. Perhaps you forgot to call execute() on the execution environment.