beta-zhou opened a new issue, #11965:
URL: https://github.com/apache/seatunnel/issues/11965
背景说明：
1.数据流，以下是通过oracle OGG同步工具抽取生产系统的数据到镜像库，seatunel抽取镜像库数据同步到doris。
oracle生产环境 - OGG - oracle镜像库 - seatunel - doris数据库
2.现象：
由于OGG同步进程异常失败了，重建OGG同步进程（重建OGG抽取进程，重新初始化数据，重建OGG应用进程），OGG同步进程修复后，发现seatunel进程失败了，一直抽取步到镜像库的数据。
3.seatunel日志：（Caused by: io.debezium.DebeziumException: Online REDO LOG
files or archive log files do not contain the offset scn 2509495408. Please
perform a new snapshot.）
具体日志记录
2026-08-26 03:06:50,127 ERROR [o.a.s.e.s.d.p.PhysicalVertex ]
[hz.main.generic-operation.thread-23] - Job (1119747415390289925), Pipeline:
[(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/1)],
taskGroupLocation: [TaskGroupLocation{jobId=1119747415390289925, pipelineId=1,
taskGroupId=2}] end with state FAILED and Exception:
java.lang.RuntimeException: One or more fetchers have encountered exception
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:147)
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:167)
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:93)
at
org.apache.seatunnel.connectors.cdc.base.source.reader.IncrementalSourceReader.pollNext(IncrementalSourceReader.java:119)
at
org.apache.seatunnel.engine.server.task.flow.SourceFlowLifeCycle.collect(SourceFlowLifeCycle.java:159)
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127)
at
org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165)
at
org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132)
at
org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:694)
at
org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1023)
at
org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
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:750)
Caused by: java.lang.RuntimeException: SplitFetcher thread 0 received
unexpected exception while polling the records
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165)
at
org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:81)
... 5 more
Caused by: 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:50)
at
io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:267)
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: io.debezium.DebeziumException: Online REDO LOG files or archive
log files do not contain the offset scn 2509495408. Please perform a new
snapshot.
at
io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:171)
... 8 more
4.经过查询镜像库SCN号已经是29开头了，但是seatunel抽取的数据2509495408，导致seatunel同步进程无法正常启动
<img width="860" height="499" alt="Image"
src="https://github.com/user-attachments/assets/9fac20af-da11-4db7-a391-d38230449578";
/>
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
