Flink中invoke之前 判断当前链接是否有效 无效就重连 我们也遇到这种情况了?
以下为热心网友提供的参考意见
在Flink中,如果需要判断当前链接是否有效并在无效时重连,可以使用以下方法:
创建一个自定义的CheckpointCoordinator实现类,用于检查连接状态并重连。
在invoke方法中,使用CheckpointCoordinator实例来检查连接状态。
如果连接无效,调用reconnect()方法进行重连。
以下为热心网友提供的参考意见
我改成了直接在iovoke里获取connection现在还没出现断连 ,此回答整理自钉群“【③群】Apache Flink China社区”
本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/22078.html