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

请问有人遇到过flink重启任务创建新的yarnApplicationId嘛

请问有人遇到过flink重启任务创建新的yarnApplicationId嘛

展开
收起
真的很搞笑 2023-05-06 22:33:37 87 0
1 条回答
写回答
取消 提交回答
  • 存在即是合理

    在Flink中,当你重启任务时,Flink需要重新创建一个新的yarnApplicationId。这是因为yarnApplicationId是用于标识Flink集群中的应用程序的唯一标识符。当你重启任务时,Flink需要重新分配一个新的yarnApplicationId,以确保在重启后应用程序可以正确地重新加载。

    要重新创建yarnApplicationId,请按照以下步骤操作:

    1、首先,确保已经停止了所有的Flink作业。在Flink的Web界面或者命令行中运行以下命令: stop all tasks

    2、接下来,在Flink的Web界面或者命令行中运行以下命令以重新创建yarnApplicationId: FLINK_HOME/bin/restart_job.sh

    这将重新启动Flink作业,并重新创建一个新的yarnApplicationId。

    请注意,在重启Flink作业之前,确保已经完成了所有必要的清理工作,例如关闭数据源、清除日志文件等。

    2023-05-08 17:34:31
    赞同 展开评论 打赏

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

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

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