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

scala中关闭任务结束后的 Checkpoint,Flink设置的时候报异常,怎么解决?

scala中关闭任务结束后的 Checkpoint,Flink设置的时候报异常,怎么解决?lQLPJxwUfqLs7sDNApbNByqwTnmgu_sSX7kE3K-ZtEAxAA_1834_662.png

展开
收起
三分钟热度的鱼 2023-08-29 19:48:44 83 0
1 条回答
写回答
取消 提交回答
  • 您好,Flink 的 Checkpoint 在任务结束后默认会自动关闭。如果您想手动关闭 Checkpoint,可以使用以下代码:

    checkpointCoordinator.close()
    如果您在使用 checkpointCoordinator.close() 方法时遇到异常,请检查以下几点:

    是否在正确的线程中调用 checkpointCoordinator.close() 方法。该方法必须在 open() 方法调用之后调用。
    是否有其他线程正在使用 checkpointCoordinator 对象。如果有其他线程正在使用 checkpointCoordinator 对象,则 checkpointCoordinator.close() 方法将无法正常关闭 Checkpoint。
    如果您仍然无法解决问题,请联系 Flink 官方支持人员。

    希望以上信息能对您有所帮助。

    2023-09-28 10:28:16
    赞同 展开评论 打赏

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

相关产品

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

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