【已解决】flink-doris-connector 1.6.1 同步oracle12c(CDB+PDB)模式下PDB表找不到问题

Viewed 85

本次使用 flink-doris-connector 1.6.1 + flink 1.17 + oracle 12c(CDB + PDB)。

flink-doris-connector 使用flink cdc 实现orcale 数据同步,在orcale是CDB+PDB模式下,只有CDB存在redo日志,所以需要指定CDB用户连接,才可以访问到redo日志实现数据抽取

如果要指定PDB去同步表,flink cdc 官方说明image.png,配置debezium.database.pdb.name ='xx'
debezium 提示提示需要配置:image.png 以及debezium.database.dbname = 使用CDB+PDB模型时,必须是CDB名称。

在 flink-doris-connector 1.6.1 源码中看到:正常加载了debezium传递的参数。image.png
接下来是加载需要同步的表信息
image.png
可以看到这里直接拿CDB的用户连接信息,去获取PDB的表,oracle 是获取不到的。

image.png
然后此处校验报错。

请问下这个是我个人理解出错,还是因为代码版本不对,又或者是数据库配置不对, 希望大佬们能看到!!!!!

4 Answers

已经修复:https://github.com/apache/doris-flink-connector/pull/423

--oracle-conf debezium.database.dbname 加这个试试

请教下,我遇到这个问题,智能获取cdb 的数据,pdb 数据获取不到