CNF96 opened a new pull request, #10416:
URL: https://github.com/apache/seatunnel/pull/10416
### Purpose of this pull request
**修复 PostgreSQL CDC 任务无法启动的致命问题**：
1. **核心问题修复**：
- 在 [PostgresSourceFetchTaskContext.configure()] 产生 Replication slot
重复创建异常。
- 原代码直接调用
`replicationConnection.createReplicationSlot().orElse(null)`，该方法：
- 未处理已创建场景，会触发重复创建异常
- 异常处理方式过于依赖错误消息文本匹配
2. **异常处理机制改进**：
- 修复了基于错误消息字符串匹配的脆弱性问题
**解决方案**：
- 替换为 `replicationConnection.initConnection()`，该方法：
- 在Debezium侧有幂等处理
### Does this PR introduce any user-facing change?
No — 仅修复底层连接初始化逻辑，不影响用户配置或输出格式
### How was this patch tested?
- ✅ 手动创建复制槽后启动 Seatunnel，验证任务成功启动（原逻辑 crash）
- ✅ 删除复制槽后启动，验证自动创建成功
### Check list
- [ ] If any new Jar binary package adding in your PR, please add License
Notice according [New License Guide]
- [ ] If necessary, please update the documentation to describe the new
feature.
- [ ] If you are contributing the connector code, please check that the
following files are updated:
i. Update
[plugin-mapping.properties](file://F:\development\opensource\seatunnel-2.3.12\plugin-mapping.properties)
and add new connector information in it
ii. Update the pom file of `seatunnel-dist`
iii. Add ci label in `label-scope-conf`
iv. Add e2e testcase in `seatunnel-e2e`
v. Update connector
[plugin_config](file://F:\development\opensource\seatunnel-2.3.12\config\plugin_config)
- [ ] Update the `release-note`.
--
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]
