开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink这个问题是啥原因?

Flink这个问题是啥原因?任务因为这个 挂了2次了。 内核版本:vvr-6.0.7-flink-1.15
4ab8169743afacd5acea0fb3b1a7ea21.png

展开
收起
嘟嘟嘟嘟嘟嘟 2024-01-17 09:45:55 40 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    这个问题的原因是无法实例化类com.ververica.platform.flink.ha.kubernetes.KuberneteshaServicesFactory,可能是因为该类没有在类路径中。请确保该类在类路径中。

    2024-01-17 14:06:33
    赞同 展开评论 打赏
  • 网站:http://ixiancheng.cn/ 微信订阅号:小马哥学JAVA

    image.png
    Flink无法实例化类 'com.ververica.platform.flink.ha.kubernetes.kubernetesHaServicesFactory'。这个类是用于创建高可用性服务(High Availability Services,HAS)的工厂。Flink需要这个类来在故障转移时保持作业的状态;

    排查步骤:
    第一、确保 'com.ververica.platform.flink.ha.kubernetes.kubernetesHaServicesFactory' 类在你的class path中。你可以通过添加相关的jar包到你的class path来解决这个问题。
    第二、检查这个类的名字是否正确,以及这个类是否存在于你的项目中。如果名字有误或者类不存在,你需要修改类的名字或者添加缺少的类。
    第三、如果这个类有访问权限问题,你需要修改类的访问权限。例如,如果这个类是私有的,你可以将它改为包私有的或者受保护的。

    2024-01-17 11:41:35
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载