Flink CDC-跨用户无法读取到数据，有谁遇到过，有解决办法吗？

在使用 Flink CDC-connector-oracle-cdc 2.1.0 版本采集 Oracle 数据库时，如果遇到跨用户无法读取数据的问题，可能是由于权限配置或 Oracle LogMiner 的限制导致的。以下是详细的分析和解决方案：

问题原因

1. Oracle 用户权限不足
   在跨用户读取数据时，Oracle 数据库需要确保当前用户具有足够的权限来访问目标表的数据。如果权限不足，可能会导致无法读取数据。

2. LogMiner 配置问题
   Oracle CDC 使用 LogMiner 技术解析日志文件。如果未正确配置 LogMiner 或未启用相关权限，可能会导致跨用户读取失败。

3. PDB 模式下的特殊限制
   如果您的 Oracle 数据库运行在多租户模式（CDB 和 PDB）下，跨用户读取可能需要额外配置 debezium.database.pdb.name 参数。

解决方案

1. 检查并配置 Oracle 用户权限

确保用于 Flink CDC 的 Oracle 用户具有以下权限： - SELECT 权限：对目标表的 SELECT 权限。 - LOGMINER 权限：包括 LOGMINING、SELECT_CATALOG_ROLE 等。 - REPLICATION 权限：允许用户读取归档日志。

可以通过以下 SQL 命令检查和授予权限：

-- 授予 SELECT 权限
GRANT SELECT ON <目标表名> TO <CDC用户>;

-- 授予 LOGMINER 相关权限
GRANT LOGMINING TO <CDC用户>;
GRANT SELECT_CATALOG_ROLE TO <CDC用户>;

-- 授予 REPLICATION 权限
GRANT CREATE SESSION TO <CDC用户>;
GRANT EXECUTE_CATALOG_ROLE TO <CDC用户>;

2. 配置 LogMiner 参数

确保 LogMiner 已正确启用，并且支持跨用户读取： - 启用补充日志
补充日志是 LogMiner 解析变更数据的基础，需确保目标表已启用补充日志：

ALTER TABLE <目标表名> ADD SUPPLEMENTAL LOG DATA (ALL) COLUMNS;

• 检查补偿日志是否开启
  使用以下命令确认补偿日志是否已启用：

  SELECT * FROM dba_log_groups WHERE table_name = '<目标表名>';
  

3. 处理 PDB 模式下的限制

如果您的 Oracle 数据库运行在多租户模式（CDB 和 PDB）下，需额外配置以下参数： - 设置 PDB 名称
在 Flink CDC 配置中添加 debezium.database.pdb.name 参数，指定目标 PDB 的名称：

debezium.database.pdb.name=<PDB名称>

• 切换到正确的容器
  确保当前会话已切换到目标 PDB：

  ALTER SESSION SET CONTAINER = <PDB名称>;
  

4. 检查字段名大小写匹配

Oracle 数据库默认将字段名转换为大写，而 Flink 中的字段名区分大小写。如果字段名不匹配，可能会导致读取失败。确保 Flink 中的字段名与 Oracle 表中的字段名完全一致。

5. 升级 Oracle CDC 版本

根据知识库资料，Dataphin V3.13 版本后使用的是 Oracle CDC 2.4 版本。如果您当前使用的版本为 2.1.0，建议升级到更高版本以获得更好的兼容性和功能支持。

验证与排查

完成上述配置后，可以通过以下步骤验证问题是否解决： 1. 检查用户权限
使用以下命令确认用户权限是否正确：

SELECT * FROM DBA_SYS_PRIVS WHERE GRANTEE = '<CDC用户>';
SELECT TABLE_NAME FROM DBA_TAB_PRIVS WHERE GRANTEE = '<CDC用户>';

1. 查看日志输出
   检查 Flink 作业日志，确认是否仍有权限或配置相关的错误信息。

2. 测试数据读取
   在 Flink 作业中执行简单的查询操作，验证是否能够成功读取跨用户的数据。

重要提醒

• 高权限账号要求：确保用于 Flink CDC 的 Oracle 用户具有 LOGIN 和 REPLICATION 权限，并且具有订阅表的 SELECT 权限。
• PDB 模式限制：在多租户模式下，跨用户读取需要特别注意 PDB 的配置和权限管理。
• 字段名匹配：确保 Flink 中的字段名与 Oracle 表中的字段名完全一致，避免因大小写问题导致读取失败。

通过以上步骤，您应该能够解决跨用户无法读取数据的问题。如果问题仍未解决，建议联系技术支持获取进一步帮助。您可以复制页面截图提供更多信息，我可以进一步帮您分析问题原因。