diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/StorageBackend.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/StorageBackend.java index f3d7f7e49f..e881154924 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/StorageBackend.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/StorageBackend.java @@ -65,8 +65,9 @@ public class StorageBackend implements ParseNode { } } else if (type == StorageBackend.StorageType.S3 && !schema.equalsIgnoreCase("s3")) { throw new AnalysisException("Invalid export path. please use valid 's3://' path."); - } else if (type == StorageBackend.StorageType.HDFS && !schema.equalsIgnoreCase("hdfs")) { - throw new AnalysisException("Invalid export path. please use valid 'HDFS://' path."); + } else if (type == StorageBackend.StorageType.HDFS && !schema.equalsIgnoreCase("hdfs") + && !schema.equalsIgnoreCase("viewfs")) { + throw new AnalysisException("Invalid export path. please use valid 'HDFS://' or 'viewfs://' path."); } else if (type == StorageBackend.StorageType.LOCAL && !schema.equalsIgnoreCase("file")) { throw new AnalysisException( "Invalid export path. please use valid '" + OutFileClause.LOCAL_FILE_PREFIX + "' path."); diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HiveMetaStoreCache.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HiveMetaStoreCache.java index ec1704547a..0a85d9ff5b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HiveMetaStoreCache.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HiveMetaStoreCache.java @@ -416,7 +416,7 @@ public class HiveMetaStoreCache { if (uri.getScheme() != null) { String scheme = uri.getScheme(); updateJobConf("fs." + scheme + ".impl.disable.cache", "true"); - if (!scheme.equals("hdfs")) { + if (!scheme.equals("hdfs") && !scheme.equals("viewfs")) { updateJobConf("fs." + scheme + ".impl", PropertyConverter.getHadoopFSImplByScheme(scheme)); } }