This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch release-1.2
in repository https://gitbox.apache.org/repos/asf/paimon.git

commit 08050cf2bc53be060499278d1985cbcb63b98b40
Author: andybj0228 <[email protected]>
AuthorDate: Sun Jun 15 09:29:00 2025 +0800

    [fs] Add a requiredOptions method to COSNLoader (#5750)
---
 .../src/main/java/org/apache/paimon/cosn/COSNLoader.java     | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git 
a/paimon-filesystems/paimon-cosn/src/main/java/org/apache/paimon/cosn/COSNLoader.java
 
b/paimon-filesystems/paimon-cosn/src/main/java/org/apache/paimon/cosn/COSNLoader.java
index 6d86fdc179..35b6c1ff28 100644
--- 
a/paimon-filesystems/paimon-cosn/src/main/java/org/apache/paimon/cosn/COSNLoader.java
+++ 
b/paimon-filesystems/paimon-cosn/src/main/java/org/apache/paimon/cosn/COSNLoader.java
@@ -25,6 +25,9 @@ import org.apache.paimon.fs.Path;
 import org.apache.paimon.fs.PluginFileIO;
 import org.apache.paimon.plugin.PluginLoader;
 
+import java.util.ArrayList;
+import java.util.List;
+
 /** A {@link PluginLoader} to load cosn. */
 public class COSNLoader implements FileIOLoader {
     private static final String COSN_JAR = "paimon-plugin-cosn";
@@ -45,6 +48,15 @@ public class COSNLoader implements FileIOLoader {
         return "cosn";
     }
 
+    @Override
+    public List<String[]> requiredOptions() {
+        List<String[]> options = new ArrayList<>();
+        options.add(new String[] {"fs.cosn.bucket.region"});
+        options.add(new String[] {"fs.cosn.userinfo.secretId"});
+        options.add(new String[] {"fs.cosn.userinfo.secretKey"});
+        return options;
+    }
+
     @Override
     public FileIO load(Path path) {
         return new COSNPluginFileIO();

Reply via email to