JinYu-WFG opened a new issue, #9847: URL: https://github.com/apache/seatunnel/issues/9847
### 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 Seatunnel2.3.9集群模式下使用sqlserver-cdc从源头库表将数据同步到目标Doris集群。先启动两个从checkpoint开始恢复运行的作业(A、B)，后启动另外两个从头开始的job作业(C、D)后。 A和B的目标表正常汇聚cdc的数据一段时间后，看日志卡在了[stream-load-upload] - start execute load的位置没有后续日志输出，C在数据基础数据汇聚完成后，和A、B出现同样的问题，只有D最后启动的作业目标表可以继续正常汇聚CDC数据(即随源表变化而变化)。 ### SeaTunnel Version 2.3.9 ### SeaTunnel Config ```conf { "env": { "shade.identifier": "base64", "job.mode": "STREAMING", "parallelism": 1, "checkpoint.timeout": "1200000", "job.name": "jobName", "checkpoint.interval": 5000 }, "source": [{ "username": "TFlfRFdTX1NZU1RFTQ==", "password": "******", "plugin_name": "SqlServer-CDC", "result_table_name": "CDCSource1755654914183", "node_code": "CDCSource1755654914183", "connection_code": "connection_code", "database-names": ["database-name"], "table-names": ["table-name"], "base-url": "jdbc:sqlserver://ip:port;databaseName=username;trustServerCertificate=true", "startup.mode": "initial", "incremental.parallelism": 1, "exactly_once": true, "debezium": { "database.trustServerCertificate": true }, "format": "default", "schema-changes.enabled": false }], "transform": [{ "plugin_name": "FieldMapper", "result_table_name": "FieldMapper1755655679713", "source_table_name": "CDCSource1755654914183", "source_node_code": "CDCSource1755654914183", "node_code": "FieldMapper1755655679713", "field_mapper": { "field1":"field1",... } }], "sink": [{ "username": "TFlEV1M=", "password": "******", "database": "database", "table": "table", "plugin_name": "Doris", "source_table_name": "FieldMapper1755655679713", "source_node_code": "FieldMapper1755655679713", "node_code": "DorisSink1755658637930", "env_type": "dev", "connection_code": "Doris", "fenodes": "ip1:8030,ip2:8030,ip3:8030", "query-port": 9030, "sink.enable-2pc": false, "sink.enable-delete": false, "sink.check-interval": 10000, "sink.max-retries": 3, "sink.buffer-size": 524288, "sink.buffer-count": 3, "doris.batch.size": 3000, "needs_unsupported_type_casting": false, "schema_save_mode": "CREATE_SCHEMA_WHEN_NOT_EXIST", "data_save_mode": "DROP_DATA", "save_mode_create_template": "CREATE TABLE `${database}`.`${table}` \n ( \n `field1`, \n ${rowtype_fields} \n ) ENGINE=OLAP \n UNIQUE KEY(`field1`)\n COMMENT '${comment}' \n DISTRIBUTED BY HASH(`order_detail_id`) \n PROPERTIES(\"replication_num\" = \"1\")", "doris.config": { "format": "json", "read_json_by_line": "true" }, "field_ide": "LOWERCASE" }] } ``` ### Running Command ```shell 暂无 ``` ### Error Exception ```log 未发现异常日志 ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
