代码里面是有env.execute,提交job出现以下错误,可能时什么原因?
The program didn't contain a Flink job. Perhaps you forgot to call execute() on 
the execution environment.

回复