nero520 opened a new issue, #9913: URL: https://github.com/apache/seatunnel/issues/9913
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened [export-2025-09-29_19-20-17.csv](https://github.com/user-attachments/files/22611559/export-2025-09-29_19-20-17.csv) Oracle CDC ERROR ojdbc11-23.2.0.0.jar connector-cdc-oracle-2.3.10.jar Deploy SeaTunnel Engine In Separated Cluster Mode When an exception occurs, the CPU utilization reaches 100%, and CDC data synchronization is interrupted. ORA-00334: archived log: '+DATA/SLTDB/ONLINELOG/group_3.269.1210932439' ,the file is exists. ### SeaTunnel Version Seatunnel 2.3.10 ### SeaTunnel Config ```conf env { parallelism = 1 job.mode = "STREAMING" checkpoint.interval = 10000 } source{ Oracle-CDC { plugin_output = "CLUSTER_CDC_MARD_INC_AUTH" base-url = "jdbc:oracle:thin:@//xxx:1521/SLTDB?CONNECT_TIMEOUT=20000&READ_TIMEOUT=600000" source.reader.close.timeout = 120000 username = "xxxx" password = "xxxxx" database-names = ["SLTDB"] schema-names = ["SPPRD"] table-names = ["SLTDB.SPPRD.MARD"] format = compatible_debezium_json startup.mode = "latest" connection.pool.size = 1 connect.max-retries = 5 snapshot.split.size = 2000 snapshot.fetch.size = 1000 connect.timeout.ms = 600000 debezium = { key.converter.schemas.enable = false value.converter.schemas.enable = false poll.interval.ms = 1000 heartbeat.interval.ms = 5000 } } } transform { } sink { kafka { plugin_input = "CLUSTER_CDC_MARD_INC_AUTH" topic = "data-dss-mard_cdc" bootstrap.servers = "xxx:9093,xxx:9093,xxx:9093" kafka.request.timeout.ms = 60000 semantics = EXACTLY_ONCE kafka.config = { acks = "all" request.timeout.ms = 60000 buffer.memory = 33554432 batch.size = 2000 linger.ms = 500 retries = 5 retry.backoff.ms = 1000 key.serializer = org.apache.kafka.common.serialization.ByteArraySerializer value.serializer = org.apache.kafka.common.serialization.ByteArraySerializer security.protocol = "SASL_PLAINTEXT" sasl.mechanism = "SCRAM-SHA-512" sasl.jaas.config = "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"xxxx\" password=\"xxxx\";" } format = compatible_debezium_json } } ``` ### Running Command ```shell ./bin/seatunnel.sh --config ./myconf/spprd/inc/CLUSTER_CDC_MARD_INC_AUTH.conf --async -n CLUSTER_CDC_MARD_INC_AUTH ``` ### Error Exception ```log ORA-00334: archived log: '+DATA/SLTDB/ONLINELOG/group_3.269.1210932439' at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:710) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.T4CTTIoer11.processError(T4CTTIoer11.java:608) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.T4C8Oall.processError(T4C8Oall.java:1335) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:1041) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:443) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:533) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:262) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:1137) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.OracleStatement.prepareDefineBufferAndExecute(OracleStatement.java:1318) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:1197) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.OracleStatement.executeSQLSelect(OracleStatement.java:1721) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1518) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3751) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3922) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1103) ~[ojdbc11-23.2.0.0.jar:23.2.0.0.0] at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.process(AbstractLogMinerEventProcessor.java:185) ~[?:?] at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:255) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.reader.fetch.logminer.OracleRedoLogFetchTask$RedoLogSplitReadTask.execute(OracleRedoLogFetchTask.java:147) ~[?:?] at org.apache.seatunnel.connectors.seatunnel.cdc.oracle.source.reader.fetch.logminer.OracleRedoLogFetchTask.execute(OracleRedoLogFetchTask.java:73) ~[?:?] at org.apache.seatunnel.connectors.cdc.base.source.reader.external.IncrementalSourceStreamFetcher.lambda$submitTask$0(IncrementalSourceStreamFetcher.java:107) ~[?:?] ... 5 more Caused by: java.sql.SQLException: ORA-00310: archived log contains sequence 1961; sequence 1959 required ``` ### Zeta or Flink or Spark Version Zeta 2.3.10 ### Java or Scala Version java -version openjdk version "17.0.15" 2025-04-15 LTS OpenJDK Runtime Environment Corretto-17.0.15.6.1 (build 17.0.15+6-LTS) OpenJDK 64-Bit Server VM Corretto-17.0.15.6.1 (build 17.0.15+6-LTS, mixed mode, sharing) ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
