flink的jdbc connector是否可以采用连接池模型？
flink的jdbc connector是否可以采用连接池模型？如果只使用一个connection，是否可以添加某种心跳机制以保持active？ 2.连接失效后是否有可能丢数（因为源码没找到存储record的state field）？ 3.在当前版本下，连接失效有什么比较好的解决方案吗？
flink jdbc connector 在checkpoint的时候出问题
JDBC connector似乎无法确保buffer中的数据在checkpoint的时候全部入库。这是因为 OutputFormat中没有一个接口，供checkpoint的时候调用。 从JDBC的connector的 代码来看，只能设定一个超时时间用以刷新数据，但还是可能存在丢数据的case。 我的问题是：是否有办法强制刷新buffer中的数据入库？ @Public public inter...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。