This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new b845813e6fb [opt](fs)add local file support for 2.1 (#45632) (#45702)
b845813e6fb is described below
commit b845813e6fb64e6f38cdc30919128a67bdae8b69
Author: wuwenchi <wuwen...@selectdb.com>
AuthorDate: Mon Dec 23 10:25:34 2024 +0800
[opt](fs)add local file support for 2.1 (#45632) (#45702)
bp: #45632
---
.../java/org/apache/doris/datasource/property/PropertyConverter.java | 3 +++
fe/fe-core/src/main/java/org/apache/doris/fs/FileSystemFactory.java | 1 +
2 files changed, 4 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
index b8e1550ecab..5a378336950 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/datasource/property/PropertyConverter.java
@@ -38,6 +38,7 @@ import com.aliyun.datalake.metastore.common.DataLakeConfig;
import com.amazonaws.glue.catalog.util.AWSGlueConfig;
import com.google.common.base.Strings;
import com.google.common.collect.Maps;
+import org.apache.hadoop.fs.LocalFileSystem;
import org.apache.hadoop.fs.aliyun.oss.AliyunOSSFileSystem;
import org.apache.hadoop.fs.s3a.Constants;
import org.apache.hadoop.fs.s3a.S3AFileSystem;
@@ -182,6 +183,8 @@ public class PropertyConverter {
public static String getHadoopFSImplByScheme(String fsScheme) {
if (fsScheme.equalsIgnoreCase("obs")) {
return ObsProperties.HadoopFsObsConstants.HADOOP_FS_OBS_CLASS_NAME;
+ } else if (fsScheme.equalsIgnoreCase("file")) {
+ return LocalFileSystem.class.getName();
} else if (fsScheme.equalsIgnoreCase("oss")) {
return AliyunOSSFileSystem.class.getName();
} else if (fsScheme.equalsIgnoreCase("cosn") ||
fsScheme.equalsIgnoreCase("lakefs")) {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/fs/FileSystemFactory.java
b/fe/fe-core/src/main/java/org/apache/doris/fs/FileSystemFactory.java
index cd7212c8e39..daa8f7e51c3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/fs/FileSystemFactory.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/fs/FileSystemFactory.java
@@ -55,6 +55,7 @@ public class FileSystemFactory {
switch (type) {
case S3:
return new S3FileSystem(properties);
+ case FILE:
case DFS:
return new DFSFileSystem(properties);
case OFS:
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
