[Bug] [Oracle-cdc] Oracle CDC ORA-00334 & ORA-00310 & cpu 100%

[nero520]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

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

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

./bin/seatunnel.sh --config ./myconf/spprd/inc/CLUSTER_CDC_MARD_INC_AUTH.conf --async -n CLUSTER_CDC_MARD_INC_AUTH

Error Exception

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

• I agree to follow this project's Code of Conduct

[LeonYoah]

#8772

[LeonYoah]

Apart from the group_3.269.1210932439 file, you need to check if a new log file has been generated in the archive directory

[nero520]

找到原因了，oracle redo文件太小短时间切换太频繁，导致显示序列断点不存在问题，redo覆盖