Hi!

如果只是 bucket 不同的话,通过在 with 参数里指定 path 即可。

如果连 ak id 和 secret
都不同,可以考虑实现自己的 com.aliyun.oss.common.auth.CredentialsProvider 接口,并在 flink
conf 中指定 fs.oss.credentials.provider 为对应的实现类。

casel.chen <[email protected]> 于2021年12月1日周三 上午8:14写道:

> flink平台作业写数据到客户oss bucket,和flink平台作业本身做checkpoint/savepoint用的oss
> bucket不是同一个。
> 请问这种场景flink是否支持,如果支持的话应该要怎么配置?谢谢!

回复