有大佬遇到过这个错误吗? io.debezium.DebeziumException: Online REDO LOG files or archive log files do not contain the offset scn 13210221423209. Please perform a new snapshot.
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
遇到您提到的错误io.debezium.DebeziumException: Online REDO LOG files or archive log files do not contain the offset scn 13210221423209. Please perform a new snapshot.
,这通常意味着Debezium在尝试从Oracle数据库的在线重做日志(Online REDO Logs)或归档日志(Archive Log Files)中寻找指定的系统变更号(SCN, System Change Number)时遇到了问题,具体到本例中是SCN 13210221423209。这个错误表明Debezium未能找到从该SCN开始的数据流,可能是因为数据不连续或者配置有误。
检查Oracle配置:
LOG_ARCHIVE_DEST_n
参数确保日志被正确保存。v$archived_log
视图确认所需SCN的日志是否已归档并可访问。重新配置Debezium:
snapshot.mode
和slot.name
来适应当前环境的需求。参考Debezium Oracle Connector文档进行适当调整。执行新的Snapshot:
snapshot.mode
为initial
或when_needed
,然后重启Debezium连接器。监控与日志分析:
资源与权限验证:
通过以上步骤,您可以系统地诊断并尝试解决此问题。如果问题依然存在,建议查阅更详细的Oracle与Debezium集成文档,或联系技术支持提供进一步的帮助。
请注意,这里提供的参考资料角标仅作为示例说明,实际回答中应根据具体情况引用知识库内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。