Flink CDC 2.3连接oracle 19c(CDB+PDB)时报错显示权限不足，这种应该咋?

Flink CDC 2.3连接oracle 19c(CDB+PDB)时报错显示权限不足，这种应该咋操作呢？之前用oracle 11时候正常？报错语句：alter session set container=cdb$root ，提示ORA-01031权限不足，当前采用PDB用户连接

展开

收起

真的很搞笑 2023-06-11 15:06:50 335 版权

阿里云 AI 助理回答

在使用Flink CDC 2.3连接Oracle 19c（CDB/PDB）时，如果出现权限不足的错误（例如ORA-01031: 权限不足），尤其是在执行ALTER SESSION SET CONTAINER=CDB$ROOT语句时，这通常与Oracle 19c的多租户架构（CDB/PDB）以及用户权限配置有关。以下是详细的排查和解决方案：

问题原因分析

CDB/PDB架构差异：
- Oracle 19c引入了多租户架构（CDB/PDB），与Oracle 11g的单实例架构不同。在CDB/PDB架构中，用户需要明确区分CDB级别的操作和PDB级别的操作。
- ALTER SESSION SET CONTAINER=CDB$ROOT语句需要CDB级别的权限，而当前使用的PDB用户可能没有足够的权限执行该操作。
权限不足：
- PDB用户默认只能访问其所属的PDB，无法直接切换到CDB根容器（CDB$ROOT）或执行CDB级别的操作。
- 如果Flink CDC需要访问CDB级别的元数据（如日志挖掘相关配置），则必须确保用户具有相应的权限。
CDC日志挖掘需求：
- Flink CDC依赖Oracle的日志挖掘功能（LogMiner）来捕获变更数据。日志挖掘相关的配置和操作通常需要CDB级别的权限。

解决方案

步骤一：确认用户权限

检查当前用户的权限：使用以下SQL语句检查当前用户是否具有必要的系统权限：
```
SELECT * FROM DBA_SYS_PRIVS WHERE GRANTEE = 'C##DBZUSER';
SELECT TABLE_NAME FROM DBA_TAB_PRIVS WHERE GRANTEE = 'C##DBZUSER';
```
- 确保用户具有ALTER SESSION、SELECT ANY TRANSACTION、LOGMINING等权限。
- 如果用户缺少这些权限，请联系DBA为用户授予权限。
检查用户是否为CDB用户：
- 在Oracle 19c中，CDC操作通常需要一个CDB级别的公共用户（以C##开头）。
- 如果当前用户是PDB用户（非公共用户），则需要创建一个CDB级别的公共用户并授予相应权限。

步骤二：创建CDB公共用户

创建公共用户：在CDB根容器中创建一个公共用户（以C##开头）：

ALTER SESSION SET CONTAINER=CDB$ROOT;
CREATE USER C##FLINKCDC IDENTIFIED BY your_password;

授予必要权限：为公共用户授予CDC操作所需的权限：

GRANT CONNECT, RESOURCE, SELECT_CATALOG_ROLE TO C##FLINKCDC CONTAINER=ALL;
GRANT EXECUTE ON DBMS_LOGMNR TO C##FLINKCDC CONTAINER=ALL;
GRANT SELECT ANY TRANSACTION TO C##FLINKCDC CONTAINER=ALL;
GRANT LOGMINING TO C##FLINKCDC CONTAINER=ALL;

验证权限：切换到PDB容器，验证公共用户是否可以正常连接并执行CDC操作：
```
ALTER SESSION SET CONTAINER=PDB_NAME;
CONNECT C##FLINKCDC/your_password@PDB_NAME;
```

步骤三：调整Flink CDC配置

修改连接用户：在Flink CDC的配置中，将连接用户从PDB用户更改为CDB公共用户（如C##FLINKCDC）。
启用日志挖掘：确保Oracle数据库已启用补充日志（Supplemental Logging），这是CDC操作的必要条件：
```
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA;
ALTER DATABASE ADD SUPPLEMENTAL LOG DATA (PRIMARY KEY) COLUMNS;
```
验证日志挖掘配置：使用以下命令检查日志挖掘是否正常工作：
```
SELECT * FROM V$LOGMNR_CONTENTS WHERE SEG_NAME = 'YOUR_TABLE_NAME';
```

步骤四：测试连接

重新启动Flink作业：修改Flink CDC的连接配置后，重新启动作业，观察是否仍然报错。
监控日志：如果仍有问题，查看Flink作业日志和Oracle数据库日志，进一步排查权限或配置问题。

注意事项

CDB/PDB架构限制：
- 在Oracle 19c中，PDB用户无法直接执行CDB级别的操作。如果Flink CDC需要访问CDB级别的元数据，则必须使用CDB公共用户。
权限最小化原则：
- 授予用户权限时，遵循最小化原则，仅授予CDC操作所需的权限，避免过度授权。
兼容性问题：
- Flink CDC 2.3对Oracle 19c的支持可能存在兼容性问题。建议参考官方文档或社区版CDC连接器的使用说明。