[其他] Flink 自定义作业如何配置checkpoint保存到OBS

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信息。