关于flink1.11 新版本使用dataStreamEnv.execute 和tableEnv.execute出现No operators defined in streaming topology. Cannot generate StreamGraph.的问题

Sun, 25 Oct 2020 18:13:03 -0700 

关于flink1.11 新版本使用dataStreamEnv.execute 和tableEnv.execute出现No operators defined 
in streaming topology. Cannot generate StreamGraph.的问题


-| 程序内部使用Table API同时也有 Table转为 Datastream的场景。
-|程序内部有使用flinksql 读写kafka，从而执行 sqlUpdate  






尝试使用新版api 只使用tableEnv.executeSql 从而不加 dataStreamEnv.execute 和tableEnv.execute 
但是会出现程序执行一个开头就结束了而且没有异常。


求问新老API兼容吗？Table和Datastream同时存在的时候使用dataStreamEnv.execute 
还是tableEnv.execute？？？？？

回复