Aliyun Object Storage Service (OSS)

You can use OSS objects like regular files by specifying paths in the following format:

Below shows how to use OSS in a Flink job:

registers default FileSystem wrappers for URIs with the oss:// scheme.

Configurations setup

After setting up the OSS FileSystem wrapper, you need to add some configurations to make sure that Flink is allowed to access your OSS buckets.

You can see the configuration keys in the .

There are some required configurations that must be added to (Other configurations defined in Hadoop OSS documentation are advanced configurations which used by performance tuning):

Other credential providers can be found under here.