implement

ByteYue · Jun 27, 2024 · 684933d · 684933d
1 parent 70684dd
commit 684933d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/tablefunction/S3TableValuedFunction.java b/fe/fe-core/src/main/java/org/apache/doris/tablefunction/S3TableValuedFunction.java
@@ -96,6 +96,8 @@ public S3TableValuedFunction(Map<String, String> properties) throws AnalysisExce
 
         locationProperties = S3Properties.credentialToMap(credential);
         locationProperties.put(PropertyConverter.USE_PATH_STYLE, usePathStyle);
+        // For Azure's compatibility, we need bucket to connect to the blob storage's container
+        locationProperties.put(S3Properties.BUCKET, s3uri.getBucket());
         locationProperties.putAll(S3ClientBEProperties.getBeFSProperties(locationProperties));
         locationProperties.putAll(otherProps);