flink-sql如何-细粒度管理state

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink-sql如何-细粒度管理state

徐州州
请问一下我使用 flink sql计算日报数据,第二天的计算结果,仍然在第一天的结果上进行累加,其中计算表类型有cdc维度表和cdc事实表,如果设置全局的state清除策略会导致我维表数据丢失,请问可以单独对某张表设置  state清除策略吗?我目前使用配置
val config: TableConfig = tabEnv.getConfig
config.setIdleStateRetention(Duration.ofHours(1))