使用flink cdc读取oracle19c日志报错:ORA-01031:权限不足

[LeatherMan-Mr-Li]

已按照教程开启日志和授权，抽取日志报错
`StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

    Properties debezium = new Properties();
    debezium.setProperty("database.pdb.name", "PDBNAME");   //show pdbs;
    debezium.setProperty("database.dbname", "DBNAME");   //show pdbs;
    debezium.setProperty("snapshot.mode.configuration.based.snapshot.schema", String.valueOf(true));
    debezium.setProperty("snapshot.locking.mode","none");
    debezium.setProperty("database.tablename.case.insensitive", String.valueOf(false));
    debezium.setProperty("log.mining.strategy", "online_catalog");
    debezium.setProperty("snapshot.mode", "schema_only");
    SourceFunction<String> oracleSource = OracleSource.<String>builder()
            .url(url)
            .port(1521)
            .database(database)       // monitor XE database
            .schemaList(schemaList)   // monitor inventory schema
            .tableList(tableList)     // monitor products table
            .username(username)
            .password(password)
            .deserializer(new JsonDebeziumDeserializationSchema()) // converts SourceRecord to JSON String
            .debeziumProperties(debezium)
            .build();
    // use parallelism 1 for sink to keep message ordering
    env.addSource(oracleSource)
            .addSink(new CustomSink());
    env.execute();`

报错如下

`Caused by: java.sql.SQLSyntaxErrorException: ORA-01031: 权限不足

at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:509)
at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:461)
at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1104)
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:550)
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268)
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655)
at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229)
at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41)
at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:928)
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205)
at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1823)
at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1778)
at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:303)
at io.debezium.connector.oracle.OracleConnection.resetSessionToCdb(OracleConnection.java:102)
... 8 more

Caused by: Error : 1031, Position : 0, Sql = alter session set container=cdb$root, OriginalSql = alter session set container=cdb$root, Error Msg = ORA-01031: 权限不足

at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:513)
... 21 more`

[xuanyusa]

我也按照官网做的pipeline，数据库oracle19c，cdb数据库，也是提示权限不足。flink-cdc 3.6.0，flink 1.20.4。其中HR schema在ORCLPDB中。所有的权限都授予了，甚至最后把dba都给C##FLINK了，还是权限不足。有没有大神给想想办法啊

pipeline配置

source:
  type: oracle
  name: oracle source
  hostname: linux103
  port: 1521
  username: C##FLINK
  password: 123456
  database: ORCLPDB
  tables: HR.REGIONS
  scan.startup.mode: snapshot
  metadata.list: op_ts
  debezium.database.pdb.name: ORCLPDB
  debezium.database.history.store.only.captured.tables.ddl: true
  debezium.log.mining.strategy: online_catalog
  debezium.log.mining.continuous.mine: false
  debezium.query.fetch.size: 10000
  scan.snapshot.fetch.size: 10000

sink:
  type: kafka
  name: kafka sink
  properties.bootstrap.servers: PLAINTEXT://linux101:9092,PLAINTEXT://linux102:9092,PLAINTEXT://linux103:9092
  topic: hr

pipeline:
  name: oracle to kafka pipeline
  parallelism: 1
  schema.change.behavior: ignore

报错内容

event RequestSplitEvent (host='linux101') from subtask 0 (#1). Triggering job failover.
org.apache.flink.util.FlinkRuntimeException: Chunk splitting has encountered exception
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.checkSplitterErrors(SnapshotSplitAssigner.java:687) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.getNext(SnapshotSplitAssigner.java:402) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.HybridSplitAssigner.getNext(HybridSplitAssigner.java:182) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator.assignSplits(IncrementalSourceEnumerator.java:222) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator.handleSplitRequest(IncrementalSourceEnumerator.java:118) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.runtime.source.coordinator.SourceCoordinator.handleRequestSplitEvent(SourceCoordinator.java:634) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$handleEventFromOperator$3(SourceCoordinator.java:303) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$runInEventLoop$10(SourceCoordinator.java:530) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.util.ThrowableCatchingRunnable.run(ThrowableCatchingRunnable.java:40) [flink-dist-1.20.4.jar:1.20.4]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) [?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
	at java.base/java.lang.Thread.run(Thread.java:829) [?:?]
Caused by: java.lang.IllegalStateException: Error when splitting chunks for ORCLCDB.HR.REGIONS
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitTable(SnapshotSplitAssigner.java:361) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitChunksForRemainingTables(SnapshotSplitAssigner.java:670) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	... 3 more
Caused by: java.lang.RuntimeException: Fail to analyze table in chunk splitter.
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.analyzeTable(JdbcSourceChunkSplitter.java:368) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.generateSplits(JdbcSourceChunkSplitter.java:112) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitTable(SnapshotSplitAssigner.java:359) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitChunksForRemainingTables(SnapshotSplitAssigner.java:670) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	... 3 more
Caused by: java.sql.SQLSyntaxErrorException: ORA-01031: 权限不足

	at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:509) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:461) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1104) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:550) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:928) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1823) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1778) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:303) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at io.debezium.jdbc.JdbcConnection.lambda$execute$3(JdbcConnection.java:430) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:447) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:424) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.oracle.source.utils.OracleUtils.queryApproximateRowCnt(OracleUtils.java:60) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.oracle.source.assigner.splitter.OracleChunkSplitter.queryApproximateRowCnt(OracleChunkSplitter.java:89) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.analyzeTable(JdbcSourceChunkSplitter.java:366) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.generateSplits(JdbcSourceChunkSplitter.java:112) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitTable(SnapshotSplitAssigner.java:359) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitChunksForRemainingTables(SnapshotSplitAssigner.java:670) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	... 3 more
Caused by: oracle.jdbc.OracleDatabaseException: ORA-01031: 权限不足

	at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:513) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:461) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1104) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:550) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:928) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1823) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1778) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:303) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at io.debezium.jdbc.JdbcConnection.lambda$execute$3(JdbcConnection.java:430) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:447) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:424) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.oracle.source.utils.OracleUtils.queryApproximateRowCnt(OracleUtils.java:60) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.oracle.source.assigner.splitter.OracleChunkSplitter.queryApproximateRowCnt(OracleChunkSplitter.java:89) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.analyzeTable(JdbcSourceChunkSplitter.java:366) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.generateSplits(JdbcSourceChunkSplitter.java:112) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitTable(SnapshotSplitAssigner.java:359) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitChunksForRemainingTables(SnapshotSplitAssigner.java:670) ~[blob_p-dfb36582e5d826a82285b97700036ac597c7bf3c-e19602c3cffa65f22a0718245d0cc1ae:3.6.0-1.20]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	... 3 more
2026-06-21 10:36:01,089 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - Trying to recover from a global failure.
org.apache.flink.util.FlinkException: Global failure triggered by OperatorCoordinator for 'Source: oracle source -> SchemaOperator -> PrePartition' (operator cbc357ccb763df2852fee8c4fc7d55f2).
	at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder$LazyInitializedCoordinatorContext.failJob(OperatorCoordinatorHolder.java:651) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator$QuiesceableContext.failJob(RecreateOnResetOperatorCoordinator.java:259) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.runtime.source.coordinator.SourceCoordinatorContext.failJob(SourceCoordinatorContext.java:432) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$runInEventLoop$10(SourceCoordinator.java:544) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.util.ThrowableCatchingRunnable.run(ThrowableCatchingRunnable.java:40) ~[flink-dist-1.20.4.jar:1.20.4]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?]
	at java.base/java.lang.Thread.run(Thread.java:829) ~[?:?]
Caused by: org.apache.flink.util.FlinkRuntimeException: Chunk splitting has encountered exception
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.checkSplitterErrors(SnapshotSplitAssigner.java:687) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.getNext(SnapshotSplitAssigner.java:402) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.HybridSplitAssigner.getNext(HybridSplitAssigner.java:182) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator.assignSplits(IncrementalSourceEnumerator.java:222) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator.handleSplitRequest(IncrementalSourceEnumerator.java:118) ~[?:?]
	at org.apache.flink.runtime.source.coordinator.SourceCoordinator.handleRequestSplitEvent(SourceCoordinator.java:634) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$handleEventFromOperator$3(SourceCoordinator.java:303) ~[flink-dist-1.20.4.jar:1.20.4]
	at org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$runInEventLoop$10(SourceCoordinator.java:530) ~[flink-dist-1.20.4.jar:1.20.4]
	... 7 more
Caused by: java.lang.IllegalStateException: Error when splitting chunks for ORCLCDB.HR.REGIONS
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitTable(SnapshotSplitAssigner.java:361) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitChunksForRemainingTables(SnapshotSplitAssigner.java:670) ~[?:?]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	... 3 more
Caused by: java.lang.RuntimeException: Fail to analyze table in chunk splitter.
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.analyzeTable(JdbcSourceChunkSplitter.java:368) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.generateSplits(JdbcSourceChunkSplitter.java:112) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitTable(SnapshotSplitAssigner.java:359) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitChunksForRemainingTables(SnapshotSplitAssigner.java:670) ~[?:?]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	... 3 more
Caused by: java.sql.SQLSyntaxErrorException: ORA-01031: 权限不足

	at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:509) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:461) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1104) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:550) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:928) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1823) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1778) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:303) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at io.debezium.jdbc.JdbcConnection.lambda$execute$3(JdbcConnection.java:430) ~[?:?]
	at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:447) ~[?:?]
	at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:424) ~[?:?]
	at org.apache.flink.cdc.connectors.oracle.source.utils.OracleUtils.queryApproximateRowCnt(OracleUtils.java:60) ~[?:?]
	at org.apache.flink.cdc.connectors.oracle.source.assigner.splitter.OracleChunkSplitter.queryApproximateRowCnt(OracleChunkSplitter.java:89) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.analyzeTable(JdbcSourceChunkSplitter.java:366) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.generateSplits(JdbcSourceChunkSplitter.java:112) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitTable(SnapshotSplitAssigner.java:359) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitChunksForRemainingTables(SnapshotSplitAssigner.java:670) ~[?:?]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	... 3 more
Caused by: oracle.jdbc.OracleDatabaseException: ORA-01031: 权限不足

	at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:513) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:461) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1104) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:550) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:928) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1823) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1778) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:303) ~[ojdbc8-19.3.0.0.jar:19.3.0.0.0]
	at io.debezium.jdbc.JdbcConnection.lambda$execute$3(JdbcConnection.java:430) ~[?:?]
	at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:447) ~[?:?]
	at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:424) ~[?:?]
	at org.apache.flink.cdc.connectors.oracle.source.utils.OracleUtils.queryApproximateRowCnt(OracleUtils.java:60) ~[?:?]
	at org.apache.flink.cdc.connectors.oracle.source.assigner.splitter.OracleChunkSplitter.queryApproximateRowCnt(OracleChunkSplitter.java:89) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.analyzeTable(JdbcSourceChunkSplitter.java:366) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.splitter.JdbcSourceChunkSplitter.generateSplits(JdbcSourceChunkSplitter.java:112) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitTable(SnapshotSplitAssigner.java:359) ~[?:?]
	at org.apache.flink.cdc.connectors.base.source.assigner.SnapshotSplitAssigner.splitChunksForRemainingTables(SnapshotSplitAssigner.java:670) ~[?:?]
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) ~[?:?]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
	... 3 more