19:24
> 收件人: user-zh
> 主题: Re: flink 1.11 executeSql查询kafka表print没有输出
>
> 1.11的 TableResult.collect() 和 TableResult.print() 方法在流模式下，
> 都是exactly once语义，需要配置checkpoint才能得到结果。
>
> Best，
> Godfrey
>
> wind.fly@outlook.com 于2020年7月23日周四
> 下午7:22写道：
>
> > Hi, all
Hi,Godfrey：
加了checkpoint后确实可以了，能具体讲一下原理吗？print是在完成快照的时候顺便把结果输出了吗？或者有没有相关文档？
Best,
Junbao Zhang
发件人: godfrey he
发送时间: 2020年7月23日 19:24
收件人: user-zh
主题: Re: flink 1.11 executeSql查询kafka表print没有输出
1.11的 TableResult.collect() 和 TableResult.print() 方法在流模式下，
都是
1.11的 TableResult.collect() 和 TableResult.print() 方法在流模式下，
都是exactly once语义，需要配置checkpoint才能得到结果。
Best，
Godfrey
wind.fly@outlook.com 于2020年7月23日周四 下午7:22写道：
> Hi, all:
>
> 本人当前使用flink版本1.11.0，但是在执行executeSql后，print时没有在console打印出结果（查看kafka是一直有数据产生的）,
> sql如下:
>
>
>
Hi, all:
本人当前使用flink版本1.11.0，但是在执行executeSql后，print时没有在console打印出结果（查看kafka是一直有数据产生的）,
sql如下:
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings settings =
