开发者社区 问答 正文

Flink RocksDBStateBackend 可以设置阿里云 OSS 存储吗?

如题, 可以直接这样写吗?

env.setStateBackend(new RocksDBStateBackend(“oss://”, true));*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 15:02:06 748 分享 版权
1 条回答
写回答
取消 提交回答
  • 当然是可以的,state backend的checkpoint地址其实依赖于Flink的file system实现,只要参照文档[1]的描述,对oss进行相关配置即可。 

    [1] https://ci.apache.org/projects/flink/flink-docs-stable/deployment/filesystems/oss.html#shaded-hadoop-oss-file-system*来自志愿者整理的FLINK邮件归档

    2021-12-02 16:03:25
    赞同 展开评论