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

classic Classic list List threaded Threaded
1 message Options
me
Reply | Threaded
Open this post in threaded view
|

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

me
关于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?????