diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java index e6cbe2ef9c..1a875f0def 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ExportStmt.java @@ -236,13 +236,12 @@ public class ExportStmt extends StatementBase { URI uri = URI.create(path); String schema = uri.getScheme(); if (type == StorageBackend.StorageType.BROKER) { - if (schema == null || (!schema.equalsIgnoreCase("bos") - && !schema.equalsIgnoreCase("afs") - && !schema.equalsIgnoreCase("hdfs") + if (schema == null || (!schema.equalsIgnoreCase("hdfs") && !schema.equalsIgnoreCase("ofs") - && !schema.equalsIgnoreCase("obs"))) { - throw new AnalysisException("Invalid export path. please use valid 'HDFS://', 'AFS://' , 'BOS://', " - + "or 'ofs://' or 'obs://' path."); + && !schema.equalsIgnoreCase("obs") + && !schema.equalsIgnoreCase("s3a"))) { + throw new AnalysisException("Invalid broker path. please use valid 'hdfs://', 'ofs://', 'obs://'," + + " or 's3a://' path."); } } else if (type == StorageBackend.StorageType.S3) { if (schema == null || !schema.equalsIgnoreCase("s3")) {