[Bug] Failed to resume the task after it was paused

### 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

The task synchronizes normally during both the full and incremental stages, but once the task is paused and then resumed, it fails and cannot be resumed properly.

### SeaTunnel Version

apache-seatunnel-2.3.12

### SeaTunnel Config

```conf
{
"env" : {
"parallelism" : 2,
"job.mode" : "STREAMING",
"checkpoint.interval" : 60000,
"checkpoint.timeout" : 360000
},
"source" : [
{
"url" : "jdbc:oracle:thin:@193.111.99.10:1521/NC50",
"username" : "******",
"password" : "******",
"database-names" : [
"NC50"
],
"schema-names" : [
"NC5X"
],
"table-names" : [
"NC50.NC5X.BD_DEPTDOC",
"NC50.NC5X.BD_PSNBASDOC",
"NC50.NC5X.BD_PSNDOC",
"NC50.NC5X.BD_MEASDOC",
"NC50.NC5X.BD_INVBASDOC",
"NC50.NC5X.BD_INVMANDOC",
"NC50.NC5X.BD_INVBINDLE",
"NC50.NC5X.BD_CUBASDOC",
"NC50.NC5X.BD_CUMANDOC",
"NC50.NC5X.BD_BUSITYPE",
"NC50.NC5X.BD_STORDOC",
"NC50.NC5X.BD_CARGDOC",
"NC50.NC5X.BD_DEFDOC",
"NC50.NC5X.BD_PAYTERM",
"NC50.NC5X.BD_COSTSUBJ",
"NC50.NC5X.BD_BALATYPE",
"NC50.NC5X.BD_ACCSUBJ"
],
"table-names-config" : [
{
"table" : "NC50.NC5X.BD_DEPTDOC",
"primaryKeys" : [
"PK_DEPTDOC"
]
},
{
"table" : "NC50.NC5X.BD_PSNBASDOC",
"primaryKeys" : [
"PK_PSNBASDOC"
]
},
{
"table" : "NC50.NC5X.BD_PSNDOC",
"primaryKeys" : [
"PK_PSNDOC"
]
},
{
"table" : "NC50.NC5X.BD_MEASDOC",
"primaryKeys" : [
"PK_MEASDOC"
]
},
{
"table" : "NC50.NC5X.BD_INVBASDOC",
"primaryKeys" : [
"PK_INVBASDOC"
]
},
{
"table" : "NC50.NC5X.BD_INVMANDOC",
"primaryKeys" : [
"PK_INVMANDOC"
]
},
{
"table" : "NC50.NC5X.BD_INVBINDLE",
"primaryKeys" : [
"PK_INVBINDLE"
]
},
{
"table" : "NC50.NC5X.BD_CUBASDOC",
"primaryKeys" : [
"PK_CUBASDOC"
]
},
{
"table" : "NC50.NC5X.BD_CUMANDOC",
"primaryKeys" : [
"PK_CUMANDOC"
]
},
{
"table" : "NC50.NC5X.BD_BUSITYPE",
"primaryKeys" : [
"PK_BUSITYPE"
]
},
{
"table" : "NC50.NC5X.BD_STORDOC",
"primaryKeys" : [
"PK_STORDOC"
]
},
{
"table" : "NC50.NC5X.BD_CARGDOC",
"primaryKeys" : [
"PK_CARGDOC"
]
},
{
"table" : "NC50.NC5X.BD_DEFDOC",
"primaryKeys" : [
"PK_DEFDOC"
]
},
{
"table" : "NC50.NC5X.BD_PAYTERM",
"primaryKeys" : [
"PK_PAYTERM"
]
},
{
"table" : "NC50.NC5X.BD_COSTSUBJ",
"primaryKeys" : [
"PK_COSTSUBJ"
]
},
{
"table" : "NC50.NC5X.BD_BALATYPE",
"primaryKeys" : [
"PK_BALATYPE"
]
},
{
"table" : "NC50.NC5X.BD_ACCSUBJ",
"primaryKeys" : [
"PK_ACCSUBJ"
]
}
],
"startup.mode" : "initial",
"snapshot.split.size" : 200000,
"snapshot.fetch.size" : 5000,
"connect.timeout.ms" : 120000,
"connect.max-retries" : 5,
"connection.pool.size" : 30,
"exactly_once" : true,
"schema-changes.enabled" : false,
"source.reader.close.timeout" : 120000,
"debezium" : {
"database.oracle.jdbc.timezoneAsRegion" : "false"
},
"plugin_name" : "Oracle-CDC"
}
],
"sink" : [
{
"nodeUrls" : [
"193.111.99.52:8030"
],
"base-url" : "jdbc:mysql://193.111.99.52:9030/NC_WAREHOUSE",
"username" : "******",
"password" : "******",
"table" : "${table_name}",
"database" : "NC_WAREHOUSE",
"batch_max_rows" : 10000,
"max_retries" : 5,
"batch_max_bytes" : 67108864,
"http_socket_timeout_ms" : 180000,
"generate_sink_sql" : true,
"enable_upsert_delete" : true,
"is_exactly_once" : true,
"schema_save_mode" : "CREATE_SCHEMA_WHEN_NOT_EXIST",
"data_save_mode" : "APPEND_DATA",
"sink.parallelism" : 2,
"plugin_name" : "StarRocks"
}
]
}
```

### Running Command

```shell
./bin/seatunnel.sh -s 1071256989901783041

./bin/seatunnel.sh -r 1071256989901783041 -c ./conf/nc_bd_doc.conf --name nc_bd_doc --async
```

### Error Exception

```log
[1071256989901783041] 2026-02-06 11:27:07,521 INFO [.s.e.s.c.CheckpointCoordinator] [hz.main.generic-operation.thread-5] - Add task[1000300010001](1/1071256989901783041) to prepare close list
[1071256989901783041] 2026-02-06 11:27:07,573 INFO [r.IncrementalSourceSplitReader] [Source Data Fetcher for BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - Stream fetcher is created.
[1071256989901783041] 2026-02-06 11:27:07,589 INFO [IncrementalSourceStreamFetcher] [debezium-reader-0] - Start incremental read task for incremental split: IncrementalSplit(tableIds=[NC50.NC5X.BD_ACCSUBJ, NC50.NC5X.BD_COSTSUBJ, NC50.NC5X.BD_INVBINDLE, NC50.NC5X.BD_DEFDOC, NC50.NC5X.BD_CUMANDOC, NC50.NC5X.BD_INVBASDOC, NC50.NC5X.BD_CUBASDOC, NC50.NC5X.BD_PSNBASDOC, NC50.NC5X.BD_BUSITYPE, NC50.NC5X.BD_STORDOC, NC50.NC5X.BD_PSNDOC, NC50.NC5X.BD_BALATYPE, NC50.NC5X.BD_DEPTDOC, NC50.NC5X.BD_MEASDOC, NC50.NC5X.BD_CARGDOC, NC50.NC5X.BD_INVMANDOC, NC50.NC5X.BD_PAYTERM], startupOffset={commit_scn=11192069821:1:0f000100bebe1300, transaction_id=null, snapshot_scn=null, scn=11192069821}, stopOffset={commit_scn=0, lcr_position=null, scn=-9223372036854775808}, completedSnapshotSplitInfos=[], checkpointDataType=null, checkpointTables=[CatalogTable{tableId=Oracle.NC50.NC5X.BD_ACCSUBJ, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk942697446, columnNames=[PK_ACCSUBJ], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_ACCSUBJ_3, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_GLORGBOOK, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=BEGINYEAR, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=BEGINPERIOD, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=ENDYEAR, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=ENDPERIOD, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_ACCSUBJ, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_ACCSUBJ, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_ACCSUBJ_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_SUBJSCHEME, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=SUBJCODE, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_GLORGBOOK, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_ACCSUBJ_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=SUBJCODE, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_GLORGBOOK, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_CREATE_GLORGBOOK, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_ACCSUBJ, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_MEASDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk910718697, columnNames=[PK_MEASDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_MEASDOC_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=MEASNAME, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_MEASDOC_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=SHORTNAME, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_MEASDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_MEASDOC, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_MEASDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_PAYTERM, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1333424847, columnNames=[PK_PAYTERM], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_PAYTERM_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=TERMID, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_PAYTERM, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_PAYTERM, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_PAYTERM, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_INVBINDLE, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1443187810, columnNames=[PK_INVBINDLE], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBINDLE_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_BINDLEINVMANDOC, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_INVBINDLE, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_BALATYPE, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1515166993, columnNames=[PK_BALATYPE], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_BALATYPE_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=BALANCODE, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_BALATYPE, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_BALATYPE, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_BALATYPE_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=BALANNAME, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_BALATYPE, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_COSTSUBJ, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk868560218, columnNames=[PK_COSTSUBJ], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_COSTSUBJ_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=COSTCODE, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_COSTSUBJ, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_COSTSUBJ, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_COSTSUBJ, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_INVMANDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1750720394, columnNames=[PK_INVMANDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVMAN_6, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=SEALFLAG, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVMAN_3, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CUMANDOC, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_INVMANDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_INVMANDOC, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVMAN_4, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_DFTFACTORY, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_INVMAN_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_INVBASDOC, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVMAN_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_INVBASDOC, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_INVMANDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_DEPTDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1527002766, columnNames=[PK_DEPTDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_DEPTDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_DEPTDOC, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_DEPTDOC_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=DEPTCODE, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_DEPTDOC_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=DEPTNAME, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_DEPTDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_INVBASDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1435948688, columnNames=[PK_INVBASDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBAS_5, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=INVBARCODE, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_INVBASDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_INVBASDOC, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBAS_11, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=DEF12, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_INVBAS_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=INVCODE, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBAS_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=INVNAME, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=INVSPEC, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=INVTYPE, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBAS_10, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=CREATETIME, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBAS_3, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_INVCL, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBAS_13, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=INVPINPAI, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBAS_4, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_MEASDOC, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_INVBAS_12, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=WIDTH, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=UNIQ_INVCODE, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=INVCODE, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_INVBASDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_CUMANDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1709128307, columnNames=[PK_CUMANDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_CUMANDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CUMANDOC, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_CUMANDOC_3, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_RESPPSN1, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=IDX_121350001, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=CUSTFLAG, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_CUBASDOC, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_RESPDEPT1, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_CUMANDOC_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=CUSTFLAG, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_CUMANDOC_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_CUBASDOC, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=CUSTFLAG, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=IDX_11C220002, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CUBASDOC, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=CUSTFLAG, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_CUMANDOC_14, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CUBASDOC, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_CUMANDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_CUBASDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1394356601, columnNames=[PK_CUBASDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=INDEX_KEY, constraintName=ID_BD_CUBASDOC_10, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=DEF10, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=IDX_11D110002, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=CUSTCODE, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=ID_BD_CUBASDOC_11, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CUBASDOC1, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_CUBASDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CUBASDOC, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=IDX_11D110001, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=CUSTNAME, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_CUBASDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_BUSITYPE, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk145680006, columnNames=[PK_BUSITYPE], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_BUSITYPE, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_BUSITYPE, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_BUSITYPE, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_DEFDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1572965878, columnNames=[PK_DEFDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_DEFDOC_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=DOCCODE, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_DEFDOCLIST, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_DEFDOC_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_DEFDOCLIST, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_DEFDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_DEFDOC, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_DEFDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_PSNDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1929683312, columnNames=[PK_PSNDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_PSNDOC_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=PSNCODE, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_PSNDOC_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_PSNCL, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_PSNDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_PSNDOC, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_PSNDOC_3, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_DEPTDOC, sortType=DESC)]), ConstraintKey(constraintType=INDEX_KEY, constraintName=I_BD_PSNDOC_4, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_OM_JOB, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_PSNDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_STORDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk235626607, columnNames=[PK_STORDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_STORDOC_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=STORCODE, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_STORDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_STORDOC, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_STORDOC_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CORP, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=STORNAME, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_STORDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_CARGDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk526442240, columnNames=[PK_CARGDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_CARGDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_CARGDOC, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_CARGDOC_1, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_STORDOC, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=CSCODE, sortType=DESC)]), ConstraintKey(constraintType=UNIQUE_KEY, constraintName=I_BD_CARGDOC_2, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_STORDOC, sortType=DESC), ConstraintKey.ConstraintKeyColumn(columnName=CSNAME, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_CARGDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}, CatalogTable{tableId=Oracle.NC50.NC5X.BD_PSNBASDOC, tableSchema=TableSchema(primaryKey=PrimaryKey(primaryKey=pk1135207914, columnNames=[PK_PSNBASDOC], enableAutoId=null), constraintKeys=[ConstraintKey(constraintType=UNIQUE_KEY, constraintName=PK_BD_PSNBASDOC, columnNames=[ConstraintKey.ConstraintKeyColumn(columnName=PK_PSNBASDOC, sortType=DESC)])]), options={connector=jdbc, table-name=NC5X.BD_PSNBASDOC, url=jdbc:oracle:thin:@193.111.99.10:1521/NC50}, partitionKeys=[], comment='', catalogName='Oracle', metadata=MetadataSchema()}], historyTableChanges={NC50.NC5X.BD_ACCSUBJ=[B@6768ee03, NC50.NC5X.BD_COSTSUBJ=[B@69af0c9e, NC50.NC5X.BD_INVBINDLE=[B@6d908573, NC50.NC5X.BD_DEFDOC=[B@289206a5, NC50.NC5X.BD_CUMANDOC=[B@82aed42, NC50.NC5X.BD_INVBASDOC=[B@19f0cb25, NC50.NC5X.BD_CUBASDOC=[B@70a27e75, NC50.NC5X.BD_PSNBASDOC=[B@48bdf9ea, NC50.NC5X.BD_BUSITYPE=[B@17225d42, NC50.NC5X.BD_STORDOC=[B@8941560, NC50.NC5X.BD_PSNDOC=[B@6ba693d1, NC50.NC5X.BD_BALATYPE=[B@4cf345e6, NC50.NC5X.BD_DEPTDOC=[B@493ec977, NC50.NC5X.BD_MEASDOC=[B@61a9ea25, NC50.NC5X.BD_CARGDOC=[B@3eced5da, NC50.NC5X.BD_INVMANDOC=[B@68c46b90, NC50.NC5X.BD_PAYTERM=[B@570e628e}) exactly-once: true
[1071256989901783041] 2026-02-06 11:27:13,743 ERROR [i.d.c.o.l.LogMinerHelper ] [debezium-reader-0] - Mining session stopped due to the java.sql.SQLException: ORA-18716: {0} 不在任何时区中。DATE
https://docs.oracle.com/error-help/db/ora-18716/
[1071256989901783041] 2026-02-06 11:27:13,743 ERROR [i.d.p.ErrorHandler ] [debezium-reader-0] - Producer failure
java.sql.SQLException: ORA-18716: {0} 不在任何时区中。DATE
https://docs.oracle.com/error-help/db/ora-18716/
at oracle.jdbc.driver.TimestampAccessor.getOffsetDateTime(TimestampAccessor.java:159) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:842) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:834) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Representation.getObject(Representation.java:605) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Accessor.getObject(Accessor.java:1077) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.OracleStatement.getObject(OracleStatement.java:7461) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.InsensitiveScrollableResultSet.getObject(InsensitiveScrollableResultSet.java:704) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at io.debezium.connector.oracle.OracleConnection.lambda$getScnToTimestamp$16(OracleConnection.java:502) ~[?:?]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:642) ~[?:?]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510) ~[?:?]
at io.debezium.connector.oracle.OracleConnection.getScnToTimestamp(OracleConnection.java:501) ~[?:?]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.calculateEndScn(LogMinerStreamingChangeEventSource.java:805) ~[?:?]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:203) ~[?:?]
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) ~[?:?]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
at java.lang.Thread.run(Thread.java:840) [?:?]
[1071256989901783041] 2026-02-06 11:27:13,780 INFO [i.d.j.JdbcConnection ] [pool-218-thread-1] - Connection gracefully closed
[1071256989901783041] 2026-02-06 11:27:14,088 ERROR [.s.c.s.r.f.SplitFetcherManager] [Source Data Fetcher for BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - Received uncaught exception.
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) ~[seatunnel-transforms-v2.jar:2.3.12]
at org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:81) ~[seatunnel-transforms-v2.jar:2.3.12]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
at java.lang.Thread.run(Thread.java:840) [?:?]
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: java.sql.SQLException: ORA-18716: {0} 不在任何时区中。DATE
https://docs.oracle.com/error-help/db/ora-18716/
at oracle.jdbc.driver.TimestampAccessor.getOffsetDateTime(TimestampAccessor.java:159) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:842) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:834) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Representation.getObject(Representation.java:605) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Accessor.getObject(Accessor.java:1077) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.OracleStatement.getObject(OracleStatement.java:7461) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.InsensitiveScrollableResultSet.getObject(InsensitiveScrollableResultSet.java:704) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at io.debezium.connector.oracle.OracleConnection.lambda$getScnToTimestamp$16(OracleConnection.java:502) ~[?:?]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:642) ~[?:?]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510) ~[?:?]
at io.debezium.connector.oracle.OracleConnection.getScnToTimestamp(OracleConnection.java:501) ~[?:?]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.calculateEndScn(LogMinerStreamingChangeEventSource.java:805) ~[?:?]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:203) ~[?:?]
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
[1071256989901783041] 2026-02-06 11:27:14,088 INFO [r.IncrementalSourceSplitReader] [Source Data Fetcher for BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - Close current fetcher org.apache.seatunnel.connectors.cdc.base.source.reader.external.IncrementalSourceStreamFetcher
[1071256989901783041] 2026-02-06 11:27:14,156 INFO [i.d.j.JdbcConnection ] [pool-219-thread-1] - Connection gracefully closed
[1071256989901783041] 2026-02-06 11:27:14,156 INFO [o.a.s.c.s.c.s.r.f.SplitFetcher] [Source Data Fetcher for BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - Split fetcher 0 exited.
[1071256989901783041] 2026-02-06 11:27:14,225 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel] [5.1] Exception in org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask@78a23496
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) ~[seatunnel-transforms-v2.jar:2.3.12]
at org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:167) ~[seatunnel-transforms-v2.jar:2.3.12]
at org.apache.seatunnel.connectors.seatunnel.common.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:93) ~[seatunnel-transforms-v2.jar:2.3.12]
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) ~[seatunnel-starter.jar:2.3.12]
at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.collect(SourceSeaTunnelTask.java:127) ~[seatunnel-starter.jar:2.3.12]
at org.apache.seatunnel.engine.server.task.SeaTunnelTask.stateProcess(SeaTunnelTask.java:165) ~[seatunnel-starter.jar:2.3.12]
at org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask.call(SourceSeaTunnelTask.java:132) ~[seatunnel-starter.jar:2.3.12]
at org.apache.seatunnel.engine.server.TaskExecutionService$BlockingWorker.run(TaskExecutionService.java:679) ~[seatunnel-starter.jar:2.3.12]
at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1008) ~[seatunnel-starter.jar:2.3.12]
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43) ~[seatunnel-starter.jar:2.3.12]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
at java.lang.Thread.run(Thread.java:840) [?:?]
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) ~[seatunnel-transforms-v2.jar:2.3.12]
at org.apache.seatunnel.connectors.seatunnel.common.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:81) ~[seatunnel-transforms-v2.jar:2.3.12]
... 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: java.sql.SQLException: ORA-18716: {0} 不在任何时区中。DATE
https://docs.oracle.com/error-help/db/ora-18716/
at oracle.jdbc.driver.TimestampAccessor.getOffsetDateTime(TimestampAccessor.java:159) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:842) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:834) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Representation.getObject(Representation.java:605) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.Accessor.getObject(Accessor.java:1077) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.OracleStatement.getObject(OracleStatement.java:7461) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at oracle.jdbc.driver.InsensitiveScrollableResultSet.getObject(InsensitiveScrollableResultSet.java:704) ~[ojdbc11-23.9.0.25.07.jar:23.9.0.25.07]
at io.debezium.connector.oracle.OracleConnection.lambda$getScnToTimestamp$16(OracleConnection.java:502) ~[?:?]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:642) ~[?:?]
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510) ~[?:?]
at io.debezium.connector.oracle.OracleConnection.getScnToTimestamp(OracleConnection.java:501) ~[?:?]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.calculateEndScn(LogMinerStreamingChangeEventSource.java:805) ~[?:?]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:203) ~[?:?]
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
[1071256989901783041] 2026-02-06 11:27:14,225 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel] [5.1] taskDone, taskId = 1000200000000, taskGroup = TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}
[1071256989901783041] 2026-02-06 11:27:14,225 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel] [5.1] task 1000200000000 error with exception: [java.lang.RuntimeException: One or more fetchers have encountered exception], cancel other task in taskGroup TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}.
[1071256989901783041] 2026-02-06 11:27:14,226 INFO [a.s.c.s.c.s.r.SourceReaderBase] [BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - Closing Source Reader 0.
[1071256989901783041] 2026-02-06 11:27:14,226 WARN [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel] [5.1] Interrupted task 1000200010000 - org.apache.seatunnel.engine.server.task.TransformSeaTunnelTask@2bd761e0
[1071256989901783041] 2026-02-06 11:27:14,226 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel] [5.1] taskDone, taskId = 1000200010000, taskGroup = TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}
[] 2026-02-06 11:27:14,226 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-37] - log event: ReaderCloseEvent(createdTime=1770348434226, jobId=1071256989901783041, eventType=LIFECYCLE_READER_CLOSE)
[1071256989901783041] 2026-02-06 11:27:14,254 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel] [5.1] taskGroup TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2} complete with FAILED
[1071256989901783041] 2026-02-06 11:27:14,254 INFO [o.a.s.e.s.TaskExecutionService] [BlockingWorker-TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] - [localhost]:5801 [seatunnel] [5.1] task 1000200010000 error with exception: [java.lang.RuntimeException: One or more fetchers have encountered exception], cancel other task in taskGroup TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}.
[1071256989901783041] 2026-02-06 11:27:14,254 INFO [o.a.s.e.s.TaskExecutionService] [hz.main.seaTunnel.task.thread-1279] - [localhost]:5801 [seatunnel] [5.1] Task TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2} complete with state FAILED
[1071256989901783041] 2026-02-06 11:27:14,254 INFO [o.a.s.e.s.CoordinatorService ] [hz.main.seaTunnel.task.thread-1279] - [localhost]:5801 [seatunnel] [5.1] Received task end from execution TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}, state FAILED
[] 2026-02-06 11:27:14,255 INFO [o.a.s.a.e.LoggingEventHandler ] [hz.main.generic-operation.thread-9] - log event: WriterCloseEvent(createdTime=1770348434254, jobId=1071256989901783041, eventType=LIFECYCLE_WRITER_CLOSE)
[1071256989901783041] 2026-02-06 11:27:14,256 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-1279] - Job (1071256989901783041), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/2)], taskGroupLocation: [TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] turned from state RUNNING to FAILED.
[1071256989901783041] 2026-02-06 11:27:14,256 INFO [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-1279] - Job (1071256989901783041), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/2)], taskGroupLocation: [TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] state process is stopped
[1071256989901783041] 2026-02-06 11:27:14,256 ERROR [o.a.s.e.s.d.p.PhysicalVertex ] [hz.main.seaTunnel.task.thread-1279] - Job (1071256989901783041), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/2)], taskGroupLocation: [TaskGroupLocation{jobId=1071256989901783041, 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:679)
at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1008)
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
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: java.sql.SQLException: ORA-18716: {0} 不在任何时区中。DATE
https://docs.oracle.com/error-help/db/ora-18716/
at oracle.jdbc.driver.TimestampAccessor.getOffsetDateTime(TimestampAccessor.java:159)
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:842)
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:834)
at oracle.jdbc.driver.Representation.getObject(Representation.java:605)
at oracle.jdbc.driver.Accessor.getObject(Accessor.java:1077)
at oracle.jdbc.driver.OracleStatement.getObject(OracleStatement.java:7461)
at oracle.jdbc.driver.InsensitiveScrollableResultSet.getObject(InsensitiveScrollableResultSet.java:704)
at io.debezium.connector.oracle.OracleConnection.lambda$getScnToTimestamp$16(OracleConnection.java:502)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:642)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510)
at io.debezium.connector.oracle.OracleConnection.getScnToTimestamp(OracleConnection.java:501)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.calculateEndScn(LogMinerStreamingChangeEventSource.java:805)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:203)
... 8 more

[1071256989901783041] 2026-02-06 11:27:14,256 INFO [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-9] - Job (1071256989901783041), Pipeline: [(1/1)], task: [pipeline-1 [Source[0]-Oracle-CDC]-SourceTask (1/2)], taskGroupLocation: [TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2}] future complete with state FAILED
[1071256989901783041] 2026-02-06 11:27:14,256 ERROR [o.a.s.e.s.d.p.SubPlan ] [seatunnel-coordinator-service-9] - Task TaskGroupLocation{jobId=1071256989901783041, pipelineId=1, taskGroupId=2} Failed in Job nc_bd_doc (1071256989901783041), Pipeline: [(1/1)], Begin to cancel other tasks in this pipeline.
```

### Zeta or Flink or Spark Version

oracle 数据库版本是11
ojdbc11-23.9.0.25.07.jar

### Java or Scala Version

_No response_

### Screenshots

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:679)
at org.apache.seatunnel.engine.server.TaskExecutionService$NamedTaskWrapper.run(TaskExecutionService.java:1008)
at org.apache.seatunnel.api.tracing.MDCRunnable.run(MDCRunnable.java:43)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:840)
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: java.sql.SQLException: ORA-18716: {0} 不在任何时区中。DATE
https://docs.oracle.com/error-help/db/ora-18716/
at oracle.jdbc.driver.TimestampAccessor.getOffsetDateTime(TimestampAccessor.java:159)
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:842)
at oracle.jdbc.driver.Redirector$33.redirect(Redirector.java:834)
at oracle.jdbc.driver.Representation.getObject(Representation.java:605)
at oracle.jdbc.driver.Accessor.getObject(Accessor.java:1077)
at oracle.jdbc.driver.OracleStatement.getObject(OracleStatement.java:7461)
at oracle.jdbc.driver.InsensitiveScrollableResultSet.getObject(InsensitiveScrollableResultSet.java:704)
at io.debezium.connector.oracle.OracleConnection.lambda$getScnToTimestamp$16(OracleConnection.java:502)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:642)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510)
at io.debezium.connector.oracle.OracleConnection.getScnToTimestamp(OracleConnection.java:501)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.calculateEndScn(LogMinerStreamingChangeEventSource.java:805)
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:203)
... 8 more

### Are you willing to submit PR?

- [x] 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)

Start with the pause and resume commands and the failure log, especially CheckpointCoordinator, IncrementalSourceSplitReader, and IncrementalSourceStreamFetcher. Reproduce the failure using the supplied SeaTunnel configuration, then trace checkpoint restoration during resume. Done means the streaming task resumes successfully after being paused without the reported failure.

Written by the indexing model from the issue text.