You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by xiao cai <fl...@163.com> on 2020/09/27 07:47:11 UTC

Flink SQL如何设置checkpoint的TTL

Hi:
目前想了解下载Flink SQL下该如何设置checkpoint的TTL。
非常感谢指教


Best,
xiao.

回复：Flink SQL如何设置checkpoint的TTL

Posted by 111 <xi...@163.com>.

checkpoint是配置在env上的，所以不能直接在sql中配置，目前官方也没见到这种用法。
我这边的做法是，基于sql-gateway改造，拦截sql，自定义checkpoint语法规则。
set checkpoint xxxxx; 
就可以了


| |
xinghalo
|
|
xinghalo@163.com
|
签名由网易邮箱大师定制


在2020年09月27日 16:44，Michael Ran<gr...@163.com> 写道：
table api 有类似：<br/><br/>tableEnv.getConfig().setIdleStateRetentionTime(Time.days(1), Time.days(2));
在 2020-09-27 15:47:11，"xiao cai" <fl...@163.com> 写道：
Hi:
目前想了解下载Flink SQL下该如何设置checkpoint的TTL。
非常感谢指教


Best,
xiao.

Re:Flink SQL如何设置checkpoint的TTL

Posted by Michael Ran <gr...@163.com>.

table api 有类似：<br/><br/>tableEnv.getConfig().setIdleStateRetentionTime(Time.days(1), Time.days(2));
在 2020-09-27 15:47:11，"xiao cai" <fl...@163.com> 写道：
>Hi:
>目前想了解下载Flink SQL下该如何设置checkpoint的TTL。
>非常感谢指教
>
>
>Best,
>xiao.