Re: flink sql执行sql语句无法执行的错误-No operators defined in streaming topology. Cannot execute.

Fri, 11 Sep 2020 03:54:15 -0700 

1.flink 版本是1.11.1
streamEnv = StreamExecutionEnvironment.getExecutionEnvironment
streamBlinkSettings = 
EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build()
streamTableEnv = StreamTableEnvironment.create(streamEnv, streamBlinkSettings)
2.我在执行sql后需要转为datastream所以最后使用的是dataStreamEnv.execute("SqlPlatformRealTime”)
sql的结果Table会转为datastream然后addSink保存到kafka中。


 原始邮件 
发件人: silence<[email protected]>
收件人: user-zh<[email protected]>
发送时间: 2020年9月11日(周五) 18:49
主题: Re: flink sql执行sql语句无法执行的错误-No operators defined in streaming topology. 
Cannot execute.


没有insert语句也就是没有sink无法触发计算 -- Sent from: 
http://apache-flink.147419.n8.nabble.com/

回复