Hi
现象是正常的,
execute_sql是一个异步的方法，提交后就退出了，如果需要等待执行结果，可以调用如下方法显式地等待
sql_result = t_env.execute_sql("insert into print_sink select wd,count(wd) cnt
from sc group by wd")
sql_result.get_job_client().get_job_execution_result().result()
祝好
Leonard Xu
> 在 2020年8月12日，16:00，徐振华 写道：
>
> from
Hi,
execute_sql已经包含有了execute的意思了无非前者是异步非阻塞的，所以，你就别execute_sql之后还来一个execute了，具体你可以看下文档[1]。如果你使用execute_sql且在本地跑的话，你需要进行如下操作，否则会程序直接跑完没有结果。
result = t_env.execute_sql("你写的sql")
result.get_job_client().get_job_execution_result().result()
[1]
