Update

clients/filesystem-fuse/conf/gvfs_fuse.toml

@@ -34,5 +34,5 @@ metalake = "your_metalake"
 
 # extend settings
 [extend_config]
-access_key_id = "your access_key"
-secret_access_key = "your_secret_key"
+s3-access_key_id = "your access_key"
+s3-secret_access_key = "your_secret_key"

clients/filesystem-fuse/src/config.rs

@@ -309,11 +309,11 @@ mod test {
         assert_eq!(config.gravitino.uri, "http://localhost:8090");
         assert_eq!(config.gravitino.metalake, "test");
         assert_eq!(
-            config.extend_config.get("access_key_id"),
+            config.extend_config.get("s3-access_key_id"),
             Some(&"XXX_access_key".to_string())
         );
         assert_eq!(
-            config.extend_config.get("secret_access_key"),
+            config.extend_config.get("s3-secret_access_key"),
             Some(&"XXX_secret_key".to_string())
         );
     }

clients/filesystem-fuse/src/s3_filesystem.rs

@@ -28,6 +28,7 @@ use log::error;
 use opendal::layers::LoggingLayer;
 use opendal::services::S3;
 use opendal::{Builder, Operator};
+use std::collections::HashMap;
 use std::path::Path;
 
 pub(crate) struct S3FileSystem {
@@ -37,13 +38,26 @@ pub(crate) struct S3FileSystem {
 impl S3FileSystem {}
 
 impl S3FileSystem {
+    const S3_CONFIG_PREFIX: &'static str = "s3-";
+
     pub(crate) fn new(
         catalog: &Catalog,
         fileset: &Fileset,
         config: &AppConfig,
         _fs_context: &FileSystemContext,
     ) -> GvfsResult<Self> {
-        let mut opendal_config = config.extend_config.clone();
+        let mut opendal_config: HashMap<String, String> = config
+            .extend_config
+            .clone()
+            .into_iter()
+            .filter_map(|(k, v)| {
+                if k.starts_with(Self::S3_CONFIG_PREFIX) {
+                    Some((k.to_string(), v.to_string()))
+                } else {
+                    None
+                }
+            })
+            .collect();
 
         let bucket = extract_bucket(&fileset.storage_location)?;
         opendal_config.insert("bucket".to_string(), bucket);

clients/filesystem-fuse/tests/conf/gvfs_fuse_memory.toml

@@ -36,5 +36,5 @@ metalake = "test"
 
 # extend settings
 [extend_config]
-access_key_id = "XXX_access_key"
-secret_access_key = "XXX_secret_key"
+s3-access_key_id = "XXX_access_key"
+s3-secret_access_key = "XXX_secret_key"

clients/filesystem-fuse/tests/conf/gvfs_fuse_s3_ut.toml

@@ -36,8 +36,8 @@ metalake = "test"
 
 # extend settings
 [extend_config]
-access_key_id = "XXX_access_key"
-secret_access_key = "XXX_secret_key"
-region = "XXX_region"
-bucket = "XXX_bucket"
+s3-access_key_id = "XXX_access_key"
+s3-secret_access_key = "XXX_secret_key"
+s3-region = "XXX_region"
+s3-bucket = "XXX_bucket"
 

clients/filesystem-fuse/tests/conf/gvfs_fuse_test.toml

@@ -36,5 +36,5 @@ metalake = "test"
 
 # extend settings
 [extend_config]
-access_key_id = "XXX_access_key"
-secret_access_key = "XXX_secret_key"
+s3-access_key_id = "XXX_access_key"
+s3-secret_access_key = "XXX_secret_key"