diff --git a/hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java b/hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java index 40a8c9168..e166fc48e 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/fs/StorageSchemes.java @@ -60,6 +60,8 @@ public enum StorageSchemes { COS("cos", false), // Huawei Cloud Object Storage OBS("obs", false), + // Kingsoft Standard Storage ks3 + KS3("ks3", false), // Baidu Object Storage BOS("bos", false); diff --git a/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java b/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java index 8c4195f38..a346a673a 100644 --- a/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java +++ b/hudi-common/src/test/java/org/apache/hudi/common/fs/TestStorageSchemes.java @@ -46,6 +46,7 @@ public class TestStorageSchemes { assertFalse(StorageSchemes.isAppendSupported("dbfs")); assertFalse(StorageSchemes.isAppendSupported("cos")); assertFalse(StorageSchemes.isAppendSupported("bos")); + assertFalse(StorageSchemes.isAppendSupported("ks3")); assertTrue(StorageSchemes.isAppendSupported("ofs")); assertThrows(IllegalArgumentException.class, () -> { StorageSchemes.isAppendSupported("s2");