pinsisong opened a new issue, #10458: URL: https://github.com/apache/seatunnel/issues/10458
### 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 任务在全量增量阶段都同步正常，但是一旦暂停任务后再进行恢复任务既失败，无法正常恢复 ### 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=nu ll), 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_B D_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='O racle', 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)]), Const raintKey(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)]), C onstraintKey(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, columnN ames=[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=[Constrai ntKey.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(constrai ntType=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)]), Constrain tKey(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, sortT ype=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=[Constr aintKey.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.Constr aintKeyColumn(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=Tab leSchema(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(primaryK ey=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_INVMAND OC=[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) -- 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]
