Flink SQL如何设置checkpoint的TTL

2020-09-27 Thread xiao cai
Hi: 目前想了解下载Flink SQL下该如何设置checkpoint的TTL。 非常感谢指教 Best, xiao.

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

2020-09-27 Thread 111
checkpoint是配置在env上的,所以不能直接在sql中配置,目前官方也没见到这种用法。 我这边的做法是,基于sql-gateway改造,拦截sql,自定义checkpoint语法规则。 set checkpoint x; 就可以了 | | xinghalo | | xingh...@163.com | 签名由网易邮箱大师定制 在2020年09月27日 16:44,Michael Ran 写道: table api 有类似:tableEnv.getConfig().setIdleStateRetentionTime(Time.days(1), Time.days(