This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 0137c8e7f03 branch-3.0: [opt](fs)add local file support #45632 (#45686)
0137c8e7f03 is described below
commit 0137c8e7f038f2a7ccf6956fd8eb5c21103b91aa
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Dec 20 11:58:04 2024 +0800
branch-3.0: [opt](fs)add local file support #45632 (#45686)
Cherry-picked from #45632
Co-authored-by: wuwenchi <[email protected]>
---
.../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 8544ae597f1..7b65411aa6b 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
@@ -41,6 +41,7 @@ import com.google.common.base.Strings;
import com.google.common.collect.Maps;
import org.apache.hadoop.fs.CosFileSystem;
import org.apache.hadoop.fs.CosNConfigKeys;
+import org.apache.hadoop.fs.LocalFileSystem;
import org.apache.hadoop.fs.aliyun.oss.AliyunOSSFileSystem;
import org.apache.hadoop.fs.obs.OBSConstants;
import org.apache.hadoop.fs.obs.OBSFileSystem;
@@ -193,6 +194,8 @@ public class PropertyConverter {
public static String getHadoopFSImplByScheme(String fsScheme) {
if (fsScheme.equalsIgnoreCase("obs")) {
return OBSFileSystem.class.getName();
+ } 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 1f3d60d2adf..fb23005f4ac 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
@@ -63,6 +63,7 @@ public class FileSystemFactory {
return new AzureFileSystem(properties);
}
return new S3FileSystem(properties);
+ case FILE:
case DFS:
return new DFSFileSystem(properties);
case OFS:
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
