This documentation is for an out-of-date version of Apache Flink. We recommend you use the latest stable version.
Aliyun Object Storage Service (OSS) #
OSS: Object Storage Service #
Aliyun Object Storage Service (Aliyun OSS) is widely used, particularly popular among China’s cloud users, and it provides cloud object storage for a variety of use cases. You can use OSS with Flink for reading and writing data as well in conjunction with the streaming state backends
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:
// Read from OSS bucket env.readTextFile("oss://<your-bucket>/<object-name>"); // Write to OSS bucket stream.writeAsText("oss://<your-bucket>/<object-name>") // Use OSS as checkpoint storage env.getCheckpointConfig().setCheckpointStorage("oss://<your-bucket>/<object-name>");
Shaded Hadoop OSS file system #
flink-oss-fs-hadoop, copy the respective JAR file from the
opt directory to a directory in
plugins directory of your Flink distribution before starting Flink, e.g.
mkdir ./plugins/oss-fs-hadoop cp ./opt/flink-oss-fs-hadoop-1.13.6.jar ./plugins/oss-fs-hadoop/
flink-oss-fs-hadoop 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.
To allow for easy adoption, you can use the same configuration keys in
flink-conf.yaml as in Hadoop’s
You can see the configuration keys in the Hadoop OSS documentation.
There are some required configurations that must be added to
flink-conf.yaml (Other configurations defined in Hadoop OSS documentation are advanced configurations which used by performance tuning):
fs.oss.endpoint: Aliyun OSS endpoint to connect to fs.oss.accessKeyId: Aliyun access key ID fs.oss.accessKeySecret: Aliyun access key secret
CredentialsProvider can also be configured in the
# Read Credentials from OSS_ACCESS_KEY_ID and OSS_ACCESS_KEY_SECRET fs.oss.credentials.provider: com.aliyun.oss.common.auth.EnvironmentVariableCredentialsProvider
Other credential providers can be found under here.