Re: Flink RocksDBStateBackend 可以设置阿里云 OSS 存储吗?
我用oss设置,状态信息能写入,但是oss日志总是提示如下的信息,有遇到过吗? 2021-03-08 20:18:58.512 [INFO][cluster-io-thread-2]: o.a.f.f.o.s.c.a.o.c.u.LogUtils 66 logException - [Server]Unable to execute HTTP request: Not Found [ErrorCode]: NoSuchKey [RequestId]: 604616328586350B9C61 [HostId]: null -- Sent from: http://apache-flink.147419.n8.nabble.com/
Re: Flink RocksDBStateBackend 可以设置阿里云 OSS 存储吗?
Hi 王磊, 当然是可以的,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 祝好 唐云 From: Lei Wang Sent: Monday, December 28, 2020 16:21 To: user-zh@flink.apache.org Subject: Flink RocksDBStateBackend 可以设置阿里云 OSS 存储吗? 如题, 可以直接这样写吗? env.setStateBackend(new RocksDBStateBackend(“oss://”, true)); 谢谢, 王磊