是的，execute是1.10及以前使用的，execute_sql是1.11之后推荐使用的
Best,
Xingbo
lgs <9925...@qq.com> 于2020年7月21日周二 下午3:57写道：
> 谢谢。加上后就可以了。
>
> 改成原来的sql_update然后st_env.execute("job")好像也可以。
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>
谢谢。加上后就可以了。
改成原来的sql_update然后st_env.execute("job")好像也可以。
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Hi,
execute_sql是一个异步非阻塞的方法，所以你需要在你的代码末尾加上
sql_result.get_job_client().get_job_execution_result().result()
对此我已经创建了JIRA[1]
[1] https://issues.apache.org/jira/browse/FLINK-18598
Best,
Xingbo
lgs <9925...@qq.com> 于2020年7月21日周二 下午3:35写道：
> python flink_cep_example.py 过几秒就退出了，应该一直运行不退出的啊。
>
python flink_cep_example.py 过几秒就退出了，应该一直运行不退出的啊。
代码如下，使用了MATCH_RECOGNIZE：
s_env = StreamExecutionEnvironment.get_execution_environment()
b_s_settings =
EnvironmentSettings.new_instance().use_blink_planner().in_streaming_mode().build()
st_env = StreamTableEnvironment.create(s_env,
