flinkcdc2.4版本实时采集oracle19c ADG备库（只读模式），这是什么情况啊？
flinkcdc2.4版本实时采集oracle19c ADG备库（只读模式），几秒钟后程序自动结束，这是什么情况啊？用flinksql的方式没有异常信息，用datastream方式提示找不到sid。我查v$instance表，用orcl2这个sid，就会提示用户名密码错误。是因为不能创建log_mining_flush表的原因吗？oracle上也不能执行这两句，ALTER TABLE inventory.customers ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;
写回答
-
面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。这个问题可能是由于以下原因导致的：
Oracle数据库的用户名或密码错误。请检查您的Flink CDC配置文件中的Oracle连接信息，确保用户名和密码是正确的。
Oracle数据库的版本不支持ALTER TABLE语句。在Oracle 19c中，ALTER TABLE语句已经被弃用，取而代之的是使用ALTER TABLE ... ADD COLUMN子句来添加列。您可以尝试使用以下命令来添加SUPPLEMENTAL LOG DATA列：
ALTER TABLE inventory.customers ADD (supplemental_log_data VARCHAR2(4000));Oracle数据库的权限问题。请确保您的Flink CDC用户具有足够的权限来执行上述操作。您可以联系数据库管理员来获取所需的权限。
Flink CDC的配置问题。请检查您的Flink CDC配置文件，确保所有必要的配置选项都已正确设置。特别是关于Oracle数据库连接的配置，例如用户名、密码、SID等。
Oracle数据库的日志文件损坏。如果Oracle数据库的日志文件损坏，可能会导致Flink CDC无法正常采集数据。您可以尝试修复损坏的日志文件，或者从备份中恢复数据。
2023-12-12 17:36:10赞同 展开评论 打赏 -
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关文章
相关电子书
更多
