遇到 dm_flink_cdc 连接器在处理删除操作时报错的情况，可以按照以下步骤进行排查和解决：

1. 检查日志首先，查看 Flink 作业的日志，找到具体的错误信息。这可以帮助你更准确地定位问题。
2. 确认数据库配置确保达梦数据库的配置正确，特别是与 CDC 相关的配置。检查以下几点：
   数据库版本：确认使用的达梦数据库版本是否支持 CDC 功能。
   CDC 开启：确保达梦数据库的 CDC 功能已开启。
   表的主键：确保表中有主键，因为主键是识别删除记录的关键。
3. 检查 Flink 作业配置确认 Flink 作业的配置文件是否正确，特别是与删除操作相关的配置。检查以下几点：
   表的配置：确保 dm.include.tables 配置正确，包括所有需要捕获变更的表。
   删除策略：检查 dm.delete.strategy 配置，确保删除操作的处理方式正确。
4. 检查目标系统的配置如果目标系统是 Kafka 或其他消息队列，确保其配置正确，能够处理删除操作。检查以下几点：
   Kafka 配置：确保 Kafka 的配置正确，特别是 topic 和 partition 的设置。
   消息格式：确认删除操作的消息格式是否符合目标系统的期望。
5. 代码调试如果上述步骤未能解决问题，可以尝试在代码层面进行调试。以下是一个简单的调试步骤：
   添加日志：在 dm_flink_cdc 的代码中添加更多的日志输出，特别是在处理删除操作的部分。
   单元测试：编写单元测试，模拟删除操作，确保代码逻辑正确。
   示例配置以下是一个示例配置文件 flink-cdc.properties，确保删除操作的配置正确：# 达梦数据库连接信息
   dm.jdbc.url=jdbc:dm://localhost:5236
   dm.username=your_username
   dm.password=your_password
   #Kafka连接信息
   kafka.bootstrap.servers=localhost:9092
   kafka.topic=dm_changes
   #表的配置
   dm.include.tables=your_schema.your_table
   #删除策略
   dm.delete.strategy=delete
   #其他配置

可以分享下源码吗？ 瞻仰一下代码

https://eco.dameng.com/community/post/202411191132168PD86B201G3HYB7NK5
达梦官方的 dm_flink_cdc连接器 转帖及最新版本下载。里面含有示例程序和说明文档，参考下。