大佬们，有这样一个需求：将报警信息同步到 ES 中。 流程如下： 报警数据写入数据库flink cdc 同步数据库的报警信息join 一些其他表，加上附加信息写入到 ES 听起来很简单的需求，但问题是 flink 的内存一直涨，搜索一番得知是没有清除 flink 的状态，问题是我设了 ttl 清除状态，相应的数据在 ES 中就被删了，请问各位大佬是我哪里使用姿势不对吗？
