我flinkcdc的datastream形式的jar包放在flink集群上运行,可以保证这个jar包高可用吗,因为我这边有一次mysql数据库异常导致flinkcdc的监听中断了,就链接不上了,重新启动才能连接?
Flink集群本身具有高可用性,可以在任务失败时自动重启。但是,关于你的问题,有几点需要注意:
你提到的“jar包”是指Flink程序本身,还是指Flink程序依赖的其他库或数据?如果是前者,那么Flink程序本身的高可用性是由Flink集群管理的。如果是后者,那么这些库或数据的高可用性就需要你自己去管理。
如果Flink程序因为某些原因(如数据库连接问题)而失败,那么Flink集群会自动重启它。但是,如果Flink程序因为某些内部错误(如代码错误或数据问题)而失败,那么Flink集群可能无法自动修复它。
对于数据库连接问题,你可以考虑使用连接池来减少连接创建和关闭的开销。此外,你也可以考虑使用连接重试策略来处理短暂的网络中断。
对于代码错误或数据问题,你需要定期检查Flink作业的日志,以便及时发现和处理问题。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。