Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
flink-sql如何-细粒度管理state
Classic
List
Threaded
♦
♦
Locked
1 message
徐州州
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))
Free forum by Nabble
Edit this page