[FLINK-34890] io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource :.java.sql.SQLException: ORA-01291: missing log file

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Flink CDC
• Labels: github-import
• Assignee: Unassigned
• Reporter: Flink CDC Issue Import
• Created: 20/Mar/24 09:42
• Updated: 20/Mar/24 09:44

Description

1. 1. 1. Search before asking

• [X] I searched in the [issues](https://github.com/ververica/flink-cdc-connectors/issues) and found nothing similar.

1. 1. 1. Flink version

1.14.2

1. 1. 1. Flink CDC version

<flink-connector-oracle-cdc.version>2.4.1</flink-connector-oracle-cdc.version>

1. 1. 1. Database and its version

oracle19c

1. 1. 1. Minimal reproduce step

2023-11-03 13:37:44.675 WARN [debezium-oracleconnector-oracle_logminer-change-event-source-coordinator] io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource : Failed to start Oracle LogMiner session, retrying...
2023-11-03 13:37:45.286 ERROR[debezium-oracleconnector-oracle_logminer-change-event-source-coordinator] io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource : Failed to start Oracle LogMiner after '5' attempts.

java.sql.SQLException: ORA-01291: missing log file
ORA-06512: at "SYS.DBMS_LOGMNR", line 72
ORA-06512: at line 1

at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:509) ~[com.oracle.database.jdbc-ojdbc8-19.3.0.0.jar!/:19.3.0.0.0]
at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:461) ~[com.oracle.database.jdbc-ojdbc8-19.3.0.0.jar!/:19.3.0.0.0]  

 

In addition, I clean the archive logs by executing commands from the rman tool command:
------------------------------------------------------------
Crosscheck archivelog all;
Delete noprompt archivelog until time 'sysdate -1';
------------------------------------------------------------

Through the above command, the archived logs were retained for one day. During the insertion, deletion, and modification of the table within one day, I also encountered the issue of losing the logs mentioned above.

May I ask how to solve this problem。

1. 1. 1. What did you expect to see?

flink cdc normal run

1. 1. 1. What did you see instead?

java.sql.SQLException: ORA-01291: missing log file
ORA-06512: at "SYS.DBMS_LOGMNR", line 72
ORA-06512: at line 1

 

 io.debezium.connector.common.BaseSourceTask : Going to restart connector after 10 sec. after a retriable exception
2023-11-03 16:09:11.458 INFO [pool-18-thread-1] io.debezium.jdbc.JdbcConnection : Connection gracefully closed
2023-11-03 16:09:11.459 INFO [debezium-engine] io.debezium.embedded.EmbeddedEngine : Retrieable exception thrown, connector will be restarted
org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted.
        at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:46) ~[debezium-core-1.9.7.Final.jar!/:1.9.7.Final]

1. 1. 1. Anything else?

No response

1. 1. 1. Are you willing to submit a PR?

• [X] I'm willing to submit a PR!

---------------- Imported from GitHub ----------------
Url: https://github.com/apache/flink-cdc/issues/2615
Created by: https://github.com/jasonhewg
Labels: bug,
Created at: Mon Dec 18 19:07:44 CST 2023
State: open