Flink SQL如何设置checkpoint的TTL

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink SQL如何设置checkpoint的TTL

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


Best,
xiao.
Reply | Threaded
Open this post in threaded view
|

Re:Flink SQL如何设置checkpoint的TTL

Michael Ran
table api 有类似:<br/><br/>tableEnv.getConfig().setIdleStateRetentionTime(Time.days(1), Time.days(2));
在 2020-09-27 15:47:11,"xiao cai" <[hidden email]> 写道:
>Hi:
>目前想了解下载Flink SQL下该如何设置checkpoint的TTL。
>非常感谢指教
>
>
>Best,
>xiao.
111
Reply | Threaded
Open this post in threaded view
|

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

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


| |
xinghalo
|
|
[hidden email]
|
签名由网易邮箱大师定制


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


Best,
xiao.