From c486d9746d7a279f2e32deca67c14ee01c74122c Mon Sep 17 00:00:00 2001 From: xueweizhang Date: Wed, 26 Oct 2022 09:22:38 +0800 Subject: [PATCH] [fix](broker) fix bug when broker load with s3a (#13650) Signed-off-by: nextdreamblue Signed-off-by: nextdreamblue --- .../java/org/apache/doris/analysis/ExportStmt.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) 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")) {