flink的jdbc connector是否可以采用连接池模型?如果只使用一个connection,
flink的jdbc connector是否可以采用连接池模型?如果只使用一个connection,是否可以添加某种心跳机制以保持active? 2.连接失效后是否有可能丢数(因为源码没找到存储record的state field)? 3.在当前版本下,连接失效有什么比较好的解决方案吗?加了这个又找不到30得了,我使用的是自定义mysql, 这些参数在那个地方设置?soure 吗?
flink的jdbc connector是否可以采用连接池模型?
flink的jdbc connector是否可以采用连接池模型?如果只使用一个connection,是否可以添加某种心跳机制以保持active? 2.连接失效后是否有可能丢数(因为源码没找到存储record的state field)? 3.在当前版本下,连接失效有什么比较好的解决方案吗?
flink的jdbc connector是否可以采用连接池模型?
最近使用flink处理数据写入mysql sink,但由于业务场景在晚上没有数据流入,会触发mysql wait timeout限制(默认的8小时)导致连接失效。 即使在mysql url中添加了autoReconnect=true参数,仍会产生相应的异常,具体信息见下。 版本信息: flink 1.10.1 mysql server 5.6.47 mysql Connector/J 5.1......
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。