From d6f93a0f88a4c55d184797f506bd56eaf7878f11 Mon Sep 17 00:00:00 2001
From: ByteYue <yj976240184@gmail.com>
Date: Thu, 27 Jun 2024 17:57:39 +0800
Subject: [PATCH] adapt

---
 .../apache/doris/tablefunction/S3TableValuedFunction.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 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
index 61084769e8b98e..816042de9266a7 100644
--- 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,8 +96,10 @@ 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());
+        if (isAzureTvf) {
+            // 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);