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 --savepointPath /tmp/savepoints d69301ce5772186fb26aa193640ca46f --target kubernetes-application -Dkubernetes.cluster-id=toll-pro-aa -Dkubernetes.namespace=flink -Dakka.client.timeout=300s
CopyCopy
请确保在执行此命令之前,您的Flink作业已经运行在Kubernetes集群上,并且您具有相应的权限来停止和保存Savepoint。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。