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

flink on k8s 的application模式怎么从保存点重启的呀?

flink on k8s 的application模式怎么从保存点重启的呀?

展开
收起
wenti 2023-03-15 11:28:21 921 0
2 条回答
写回答
取消 提交回答
  • 全栈JAVA领域创作者

    在Flink on Kubernetes中,可以通过以下步骤从保存点重新启动应用程序:

    配置保存点:在应用程序代码中使用StateBackend将状态保存到指定的位置。例如,在使用RocksDBStateBackend时,可以设置state.backend.rocksdb.checkpoint-directory属性来指定保存点目录。

    生成保存点:当应用程序正在运行时,可以使用Flink的REST API调用/jobs/:jobid/savepoints接口生成保存点。例如,可以使用以下命令向正在运行的Flink集群生成一个保存点:

    curl -X POST http://:8081/jobs//savepoints 其中,是Flink REST API服务器的地址,是要生成保存点的应用程序的ID。

    下载保存点:在生成保存点之后,可以使用同样的REST API调用下载保存点。例如,可以使用以下命令从Flink集群下载保存点:

    curl -X GET http://:8081/savepoints/ -o 其中,是保存点的路径,是要保存到本地文件系统的文件路径。

    启动应用程序:在下载保存点后,可以使用flink run命令启动应用程序,并使用-s参数指定保存点的路径。例如:

    flink run -s file:///path/to/savepoint 其中,file:///path/to/savepoint是保存点的本地文件路径,是应用程序代码的JAR包路径。

    需要注意的是,在使用Flink on Kubernetes时,还需要将Flink作业管理器和任务管理器部署到Kubernetes集群中,并使用Kubernetes Operator来配置和管理Flink作业。具体操作方式可以参考Flink官方文档和Kubernetes官方文档。

    2023-03-16 07:58:50
    赞同 展开评论 打赏
  • 十分耕耘,一定会有一分收获!

    楼主你好,flink on k8s 的application模式很简单,你可以通过一条命令就可搞定:

    ./bin/flink run-application -p 2 -t kubernetes-application \
        -Dkubernetes.cluster-id=app-cluster-demo \
        -Dtaskmanager.memory.process.size=1024m \   
     -Dkubernetes.taskmanager.cpu=2 \   
     -Dtaskmanager.numberOfTaskSlots=2 \   
     -Dkubernetes.container.image=demo-flink-app:1.12.1 \   
     -pyfs /opt/python_codes \    -pym _word_count   
    
    2023-03-16 07:58:50
    赞同 展开评论 打赏

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

相关产品

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

    更多
    ACK 云原生弹性方案—云原生时代的加速器 立即下载
    ACK集群类型选择最佳实践 立即下载
    企业运维之云原生和Kubernetes 实战 立即下载

    相关镜像