Oracle CDC 2.2.0 报错 Caused by: java.sql.SQLException: ORA-01289: cannot add duplicate logfile +DATA/jxr2p/onlinelog/group_4.294.1016480325

[szhengshuai]

Describe the bug(Please use English) A clear and concise description of what the bug is.

Environment :

Flink version : 1.13.3 Flink CDC version: 2.2.0 Database and version: Oracle 11g RAC To Reproduce Steps to reproduce the behavior:

Thes test data : The test code : The error : Additional Description 2022-05-10 11:00:37 org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:208) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:152) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:119) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.sql.SQLException: ORA-01289: cannot add duplicate logfile +DATA/jxr2p/onlinelog/group_4.294.1016480325 ORA-06512: at "SYS.DBMS_LOGMNR", line 68 ORA-06512: at line 1

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.T4CCallableStatement.doOall8(T4CCallableStatement.java:265) at oracle.jdbc.driver.T4CCallableStatement.doOall8(T4CCallableStatement.java:86) at oracle.jdbc.driver.T4CCallableStatement.executeForRows(T4CCallableStatement.java:965) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205) at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3666) at oracle.jdbc.driver.T4CCallableStatement.executeInternal(T4CCallableStatement.java:1358) at oracle.jdbc.driver.OraclePreparedStatement.execute(OraclePreparedStatement.java:3778) at oracle.jdbc.driver.OracleCallableStatement.execute(OracleCallableStatement.java:4251) at oracle.jdbc.driver.OraclePreparedStatementWrapper.execute(OraclePreparedStatementWrapper.java:1081) at io.debezium.connector.oracle.logminer.LogMinerHelper.executeCallableStatement(LogMinerHelper.java:693) at io.debezium.connector.oracle.logminer.LogMinerHelper.setRedoLogFilesForMining(LogMinerHelper.java:491) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.initializeRedoLogsForMining(LogMinerStreamingChangeEventSource.java:245) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:168) ... 7 more Caused by: Error : 1289, Position : 0, Sql = BEGIN sys.dbms_logmnr.add_logfile(LOGFILENAME => '+DATA/jxr2p/onlinelog/group_4.294.1016480325', OPTIONS => DBMS_LOGMNR.ADDFILE);END;, OriginalSql = BEGIN sys.dbms_logmnr.add_logfile(LOGFILENAME => '+DATA/jxr2p/onlinelog/group_4.294.1016480325', OPTIONS => DBMS_LOGMNR.ADDFILE);END;, Error Msg = ORA-01289: cannot add duplicate logfile +DATA/jxr2p/onlinelog/group_4.294.1016480325 ORA-06512: at "SYS.DBMS_LOGMNR", line 68 ORA-06512: at line 1

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

[szhengshuai]

看到debezium 已经解决了 https://issues.redhat.com/browse/DBZ-3563 想知道flink-cdc什么时候可以更新debezium依赖，解决掉这个bug

[Mint-Boy-He]

Hello bro, I have the same problem, but I use datastream API, and my version is as follows: flink 1.14.4 Oracle 11g RAC, Oracle CDC 2.2.1, have you solved it?

[szhengshuai]

Hello bro, I have the same problem, but I use datastream API, and my version is as follows: flink 1.14.4 Oracle 11g RAC, Oracle CDC 2.2.1, have you solved it?

我跳过这个问题了， 直接用单机版的Oracle 19c，没有问题

[kekebi]

Hello bro, I have the same problem, but I use datastream API, and my version is as follows: flink 1.14.4 Oracle 11g RAC, Oracle CDC 2.2.1, have you solved it?

我跳过这个问题了， 直接用单机版的Oracle 19c，没有问题

你好怎么跳过这个问题的，我的作业跑一段时间就会出现这个错误导致flink 任务失败

[290352095]

你好，这个问题解决了吗？

[gong]

Closing this issue because it was created before version 2.3.0 (2022-11-10). Please try the latest version of Flink CDC to see if the issue has been resolved. If the issue is still valid, kindly report it on Apache Jira under project Flink with component tag Flink CDC. Thank you! cc @GOODBOY008

[PatrickRen]

Closing this issue because it was created before version 2.3.0 (2022-11-10). Please try the latest version of Flink CDC to see if the issue has been resolved. If the issue is still valid, kindly report it on Apache Jira under project Flink with component tag Flink CDC. Thank you!