flink oracle cdc里创建的LOG_MINING_FLUSH表是干什么用的？
版本：2.4.1
我发现flink oracle cdc里会创建一个LOG_MINING_FLUSH表，并持续写入CURRENT_SCN。我在代码里没有找到读LOG_MINING_FLUSH这个表的地方，什么时候会读这个表呢？如果只写不读的话维护这个表是做什么的呢？
由于目前只有oracle备库的只读权限，如果去掉LOG_MINING_FLUSH这个表的写入操作cdc过程是否还可以跑得起来呢？
写回答
-
-
请问最后您是怎么解决这个问题的?我目前遇到的问题是需要监控从库，不能在从库建这个表，从库只能读不能写也不能建表，应该怎么监控呢？
2023-11-07 17:28:53赞同 展开评论 打赏 -
LOG_MINING_FLUSH 表在 Flink CDC 中用于存储已刷新的 CDC 日志。当 Flink CDC 处理到一个 CDC 日志时，它会将该 CDC 日志写入 LOG_MINING_FLUSH 表。如果 Flink CDC 出现故障，则可以通过查询 LOG_MINING_FLUSH 表来恢复处理。
以下是 LOG_MINING_FLUSH 表的结构：
op_type：DML 操作类型，例如 "INSERT"、"UPDATE" 和 "DELETE"。
table_name：被修改的表名。
before：表中被修改的数据之前的值。
after：表中被修改的数据之后的值。
ts：CDC 日志的时间戳。
更多关于 Flink CDC 的详细信息，请参考 官方文档.2023-09-28 10:39:35赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关课程
更多
相关文章
相关电子书
更多
