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

flink1.13.6版本的任务,有自己重新起了个任务的吗?

flink1.13.6版本的任务,运行好多天之后任务变成了success状态,有自己重新起了个任务的吗?image.png

展开
收起
真的很搞笑 2024-02-06 22:44:54 24 0
1 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    根据日志信息,可以看到Flink任务在执行过程中出现了异常,导致任务失败。具体错误信息如下:

    Scheduler is being stopped, JobMaster is stopping.
    java.lang.Throwable: Scheduler is being stopped, JobMaster is stopping.
        at org.apache.flink.runtime.scheduler.DefaultScheduler.schedule(DefaultScheduler.java:607)
        at org.apache.flink.runtime.resourcemanager.ActiveResourceManager.lambda$schedule$2(ActiveResourceManager.java:962)
        at org.apache.flink.runtime.jobmaster.JobMaster.stopJobExecution(JobMaster.java:926)
        at org.apache.flink.runtime.jobmaster.JobMaster.onStop(JobMaster.java:398)
        at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:214)
        at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControllerMessage(AkkaRpcActor.java:563)
        at akka.japi.pf.UnitCaseStatement.apply(Casestatements.scala:26)
        at akka.japi.pf.UnitCaseStatement.apply(Casestatements.scala:21)
    

    这个错误是由于调度器被停止导致的,可能是由于其他问题引起的。为了解决这个问题,可以尝试以下步骤:

    1. 检查Flink集群的状态,确保所有组件正常运行。
    2. 检查任务的配置文件和代码,确保没有错误或不一致的地方。
    3. 查看任务的日志文件,查找是否有其他错误信息或警告。
    4. 如果可能,尝试在其他环境中运行相同的任务,以排除环境问题。
    2024-02-07 15:04:54
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载