Flink应该如何保存savepoint呢？我写的保存语句如下。也不对，是吗？ -[阿里云_云淘科技]

匿名 • 2023年12月25日上午8:08 • 阿里云

Flink应该如何保存savepoint呢？我写的保存语句如下。也不对，是吗？
bin/flink stop \
–savepointPath /tmp/savepoints \
d69301ce5772186fb26aa193640ca46f \
–target kubernetes-application \
-Dkubernetes.cluster-id=toll-pro-aa \
-Dkubernetes.namespace=flink \
-Dakka.client.timeout=300s

以下为热心网友提供的参考意见

我用flink独立模式读取本地是可以的，容器没用过，所以建议你用文件系统存储检查点和保存点，此回答整理自钉群“【③群】Apache Flink China社区”

以下为热心网友提供的参考意见

是的，您的保存语句是正确的。您使用的是Flink的命令行界面（CLI）来停止Flink作业并保存Savepoint。
请按照以下步骤操作：

使用bin/flink stop命令停止正在运行的Flink作业。
使用–savepointPath选项指定Savepoint文件的保存路径。在这个例子中，您将Savepoint保存到了/tmp/savepoints目录下。
使用–target选项指定要停止的作业的ID。在这个例子中，您要停止的作业ID是d69301ce5772186fb26aa193640ca46f。
使用-Dkubernetes.cluster-id和-Dkubernetes.namespace选项指定Kubernetes集群的ID和命名空间。在这个例子中，您指定的集群ID是toll-pro-aa，命名空间是flink。
使用-Dakka.client.timeout选项指定Akka客户端的超时时间。在这个例子中，您将超时时间设置为了300s。
您的完整保存语句如下：

bin/flink stop –savepointPath /tmp/savepoints d69301ce5772186fb26aa193640ca46f –target kubernetes-application -Dkubernetes.cluster-id=toll-pro-aa -Dkubernetes.namespace=flink -Dakka.client.timeout=300s
CopyCopy

请确保在执行此命令之前，您的Flink作业已经运行在Kubernetes集群上，并且您具有相应的权限来停止和保存Savepoint。

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/18630.html