Flink CDC 里像jdbc sink有没有调试日志啊？

• 开启Flink作业日志：

在运行Flink作业时，可以通过配置Flink的日志级别来获取更详细的执行信息。通常可以设置log4j.properties或通过环境变量调整日志级别至DEBUG或TRACE级别，以便查看sink端的详细调试信息。

• 检查Flink任务状态和日志：

查看Flink任务管理界面或日志文件，确认Flink作业是否正常运行且Sink子任务没有异常。
特别关注与JDBC Sink相关的日志输出，包括连接数据库、发送SQL语句以及处理结果等环节是否有错误提示。

• 检查数据库连接及权限：

确保Flink作业中的JDBC连接参数正确无误，例如URL、用户名、密码、数据库名等。
检查所使用的数据库账号是否具有插入目标表的权限。

• 查看事务和一致性保证：

考虑到Flink CDC和JDBC Sink可能涉及事务性操作，确保sink配置支持所需的事务一致性和重试策略，比如启用两阶段提交（Two Phase Commit, 2PC）以增强容错能力。

• 观察实时日志输出：

如果Flink作业启用了checkpoint或savepoint，并且有数据持久化机制，可以观察checkpoint成功后sink是否正确commit了事务。
如果开启了回滚策略，在遇到失败的情况下，需要确保失败时能够正确恢复和重新尝试。

• 验证sink代码逻辑：

若自定义了JDBC sink实现，检查其代码逻辑确保在成功处理事件后，确实执行了INSERT或其他更新数据库的操作。

• 测试点对点插入：

单独编写一个简单的程序，直接使用相同的JDBC连接信息插入一条数据到数据库，以排除非Flink相关的问题。

• 监控数据库端：

在数据库端开启审计日志或查询分析器，观察是否有来自Flink CDC的连接和插入尝试。