本次使用 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 官方说明,配置debezium.database.pdb.name ='xx'
debezium 提示提示需要配置: 以及debezium.database.dbname = 使用CDB+PDB模型时,必须是CDB名称。
在 flink-doris-connector 1.6.1 源码中看到:正常加载了debezium传递的参数。
接下来是加载需要同步的表信息
可以看到这里直接拿CDB的用户连接信息,去获取PDB的表,oracle 是获取不到的。
然后此处校验报错。
请问下这个是我个人理解出错,还是因为代码版本不对,又或者是数据库配置不对, 希望大佬们能看到!!!!!