Hi, 你是不是使用的flink 1.11版本,在调用了tableEnv.executeSql,最后又调用了TableEnvironment.execute或StreamExecutionEnvironment.execute方法。 可以参考[1]
[1]https://blog.csdn.net/weixin_41608066/article/details/107769826 <https://blog.csdn.net/weixin_41608066/article/details/107769826> > 2020年11月4日 下午7:20,丁浩浩 <18579099...@163.com> 写道: > > 这个任务通过读取mysql CDC 然后关联之后写入到mysql中,每次提交任务都会报错,但是会正确提交的集群上去,并且成功执行。 > 我想问问是什么原因? > ------------------------------------------------------------ > The program finished with the following exception: > > org.apache.flink.client.program.ProgramInvocationException: The main method > caused an error: No operators defined in streaming topology. Cannot execute. > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:302) > at > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:198) > at > org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:149) > at > org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:699) > at org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:232) > at > org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:916) > at > org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:992) > at > org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) > at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:992) > Caused by: java.lang.IllegalStateException: No operators defined in streaming > topology. Cannot execute. > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraphGenerator(StreamExecutionEnvironment.java:1870) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:1861) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getStreamGraph(StreamExecutionEnvironment.java:1846) > at > org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1697) > at > com.gaotu.data.performance.flink.job.sql.CeresCanRenewalWide.main(CeresCanRenewalWide.java:150) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:498) > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:288) > ... 8 more > bjhldeMacBook-Pro:flink-1.11.2 dinghh$ bin/stop-cluster.sh > Stopping taskexecutor daemon (pid: 92273) on host bjhldeMacBook-Pro.local. > Stopping standalonesession daemon (pid: 92004) on host > bjhldeMacBook-Pro.local. > bjhldeMacBook-Pro:flink-1.11.2 dinghh$ vim conf/flink-conf.yaml > bjhldeMacBook-Pro:flink-1.11.2 dinghh$ bin/start-x > -bash: bin/start-x: No such file or directory > bjhldeMacBook-Pro:flink-1.11.2 dinghh$ bin/start-cluster.sh > Starting cluster. > Starting standalonesession daemon on host bjhldeMacBook-Pro.local. > Starting taskexecutor daemon on host bjhldeMacBook-Pro.local.