I have a question that has been bothering me for 3 days, and I still haven't managed to solve it.😭😭😭 Flink version: 1.2, flinkcdc: 3.2.1, Oracle: 19c (CDB+PDB mode). When I use the following statement

FLINK SQL/CREATE TABLE oracle_prod_testQWE(
  COLUMN1 BIGINT,
  COLUMN2 STRING,
  PRIMARY KEY (COLUMN1) NOT ENFORCED
) WITH (
  'connector' = 'oracle-cdc',
  'hostname' = '<http://10.xxx|10.xxx>',
  'port' = '1521',
  'username' = 'c##xxx',
  'password' = 'xxx',
  'database-name' = 'orclCdb', 
  'schema-name' = 'APP_USER',
  'table-name' = 'TABLEZXC',
  'debezium.database.pdb.name' = 'db1cdb',
  'debezium.log.mining.strategy' = 'online_catalog',
  'debezium.snapshot.mode' = 'initial'
   );
   
FLINK SQL/select * from oracle_prod_testQWE;

My Flink job always reports this error:

xxxxxxxxxx Caused by: java.io.IOException: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-execute the snapshot.    at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:101)    at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58)    at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165)    ... 6 moreCaused by: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing. Please check database history topic configuration and re-execute the snapshot.    at io.debezium.relational.HistorizedRelationalDatabaseSchema.recover(HistorizedRelationalDatabaseSchema.java:59)    at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.validateAndLoadDatabaseHistory(OracleSourceFetchTaskContext.java:275)    at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:118)    at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceStreamFetcher.submitTask(IncrementalSourceStreamFetcher.java:84)    at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitStreamSplit(IncrementalSourceSplitReader.java:261)    at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:153)    at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98)

Sure, I'd be happy to help! Could you please provide more details about the error message? What specific error are you encountering, and what steps have you taken so far to troubleshoot the issue? The more information you can give me, the better I can assist you.😭😭😭