想问下各位大佬，有没有碰到 flink 1.17版本，使用自定义JdbcSink extends ？

想问下各位大佬，有没有碰到 flink 1.17版本，使用自定义JdbcSink extends RichSinkFunction 将数据写入到 mysql中不能成功，也没有任何报错和异常呀？
@Override
public void invoke(OplogCountDto dto, Context context) throws Exception {
logger.info("<<< insert count record:{}", dto.toString());
ps.setString(1,dto.getNs());
ps.setLong(2,dto.getDataTime());
ps.setInt(3,dto.getDs());
ps.setInt(4,dto.getCount());
ps.execute();
}
这段代码死活都看不到执行