flink的jdbc connector是否可以采用连接池模型？

我默认你指的是Sink， 因为flink jdbc connector的Source只支持Batch没有Checkpoint，jdbc connector的sink 实质写入是在flush的时候， flush会有重试机制默认3次，如果发现连接不可用就会重连,如果一直重连不上那自然就需要检查数据库情况。 至于丢数问题，flush会有3个条件触发，一个是达到条数触发，一个是checkpoint触发，一个是close触发。 当异常退出那么本次checkpoint就不会成功， 那么上游的状态保存就是在上次CHK， 重启后对于本次的CHK数据会重新消费， 可能会有重复数据，但不会丢， 当然需要上游有维护（比如kafka offset）。 此回答整理自钉群“【③群】Apache Flink China社区”