根据您提供的信息,Flink CDC集群已经成功写入了数据,并且没有报错。但是数据库中的数据没有写入到指定的时间戳2023-11-21 16:47:27。这可能是由于以下原因之一:
Flink CDC集群和数据库之间的连接存在问题。请检查网络连接、防火墙设置以及数据库的访问权限等配置是否正确。
Flink CDC集群中的加载类与数据库中的表结构不匹配。请确保Flink CDC集群中的加载类能够正确处理数据库中的表结构,包括列名、数据类型等。
Flink CDC集群中的加载类与数据库中的事务隔离级别不兼容。请检查Flink CDC集群中的加载类是否支持数据库中的事务隔离级别,或者是否需要调整事务隔离级别以适应数据库的要求。
Flink CDC集群中的加载类与数据库中的并发控制机制不兼容。请检查Flink CDC集群中的加载类是否支持数据库中的并发控制机制,或者是否需要调整并发控制机制以适应数据库的要求。
Flink CDC集群中的加载类与数据库中的其他因素有关。请检查Flink CDC集群中的加载类是否与其他因素(如数据库的缓存策略、日志记录等)相互作用,或者是否需要调整这些因素以适应数据库的要求。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。