2024-03-26 08:15:08,530 INFO org.apache.flink.kafka.shaded.org.apache.kafka.common.metrics.Metrics [] - Metrics reporters closed
2024-03-26 08:15:08,531 INFO org.apache.flink.kafka.shaded.org.apache.kafka.common.utils.AppInfoParser [] - App info kafka.producer for producer-112 unregistered
2024-03-26 08:15:08,531 INFO org.apache.flink.connector.base.source.reader.SourceReaderBase [] - Closing Source Reader.
2024-03-26 08:15:08,531 INFO org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher [] - Shutting down split fetcher 0
2024-03-26 08:15:08,698 INFO com.ververica.cdc.connectors.base.source.reader.IncrementalSourceSplitReader [] - Close current fetcher com.ververica.cdc.connectors.base.source.reader.external.IncrementalSourceStreamFetcher
2024-03-26 08:15:08,804 INFO io.debezium.jdbc.JdbcConnection [] - Connection gracefully closed
2024-03-26 08:15:08,863 ERROR io.debezium.connector.oracle.logminer.LogMinerHelper [] - Mining session stopped due to the java.sql.SQLException: ORA-01306: dbms_logmnr.start_logmnr() must be invoked before selecting from v$logmnr_contents
2024-03-26 08:15:08,863 ERROR io.debezium.pipeline.ErrorHandler [] - Producer failure
java.sql.SQLException: ORA-01306: dbms_logmnr.start_logmnr() must be invoked before selecting from v$logmnr_contents
at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:509) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:461) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1104) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:550) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:270) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:91) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:807) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:983) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1168) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3666) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.T4CPreparedStatement.executeInternal(T4CPreparedStatement.java:1426) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3713) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1167) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:193) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:247) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at com.ververica.cdc.connectors.oracle.source.reader.fetch.OracleStreamFetchTask$RedoLogSplitReadTask.execute(OracleStreamFetchTask.java:134) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at com.ververica.cdc.connectors.oracle.source.reader.fetch.OracleStreamFetchTask.execute(OracleStreamFetchTask.java:72) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at com.ververica.cdc.connectors.base.source.reader.external.IncrementalSourceStreamFetcher.lambda$submitTask$0(IncrementalSourceStreamFetcher.java:89) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
Caused by: oracle.jdbc.OracleDatabaseException: ORA-01306: dbms_logmnr.start_logmnr() must be invoked before selecting from v$logmnr_contents
at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:513) ~[flink-sql-connector-oracle-cdc-2.4.1.jar:2.4.1]
... 24 more
2024-03-26 08:15:08,864 INFO io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource [] - startScn=3425138973, endScn=3425141574