文档首页 > > 常见问题> 作业类> Flink 自定义作业如何配置checkpoint保存到OBS

Flink 自定义作业如何配置checkpoint保存到OBS

分享
更新时间:2020/01/14 GMT+08:00

CS提供将Flink的checkpoint数据保存到OBS的能力,配置的示例代码如下:

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.runtime.state.filesystem.FsStateBackend;
import org.apache.flink.contrib.streaming.state.RocksDBStateBackend;

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
RocksDBStateBackend rocksDbBackend = new RocksDBStateBackend(new FsStateBackend("obs路径"), true);
env.setStateBackend(rocksDbBackend);

其中,obs路径为obs://ak:sk@obs服务的endpoint/桶名/桶目录,ak、sk是需要上传的OBS桶所在的账号的AK/SK信息。

分享:

文档是否有解决您的问题?

提交成功!非常感谢您的反馈,我们会继续努力做到更好!
反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

智能客服提问云社区提问