Hi, What is the difference between table.exec.source.idle-timeout and setIdleStateRetentionTime ?
table.exec.source.idle-timeout: https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/config.html#table-exec-source-idle-timeout setIdleStateRetentionTime: https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/query_configuration.html#idle-state-retention-time Some context: Hi we are using flink 1.12. Our checkpoint size is constantly increasing once app is deployed. After performing a restart, checkpoint size goes back to expected size. Looking at actual checkpoint files generated, it seems our app is holding on to state/events since the time app started up. Based on our sql, the maximum time we would need to hold state is 10 minutes. This e-mail is intended only for the use of the addressees. Any copying, forwarding, printing or other use of this e-mail by persons other than the addressees is not authorized. This e-mail may contain information that is privileged, confidential and exempt from disclosure. If you are not the intended recipient, please notify us immediately by return e-mail (including the original message in your reply) and then delete and discard all copies of the e-mail. Thank you. HB75