From dfc1dbfb5901b4d373436384fa8c180f71df3b85 Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" <41898282+github-actions[bot]@users.noreply.github.com> Date: Wed, 30 Apr 2025 09:16:37 +0800 Subject: [PATCH] branch-2.1: [bugfix](chdfs) fix hash collision in chdfs file system cache #49486 (#50545) Cherry-picked from #49486 Co-authored-by: zhangyuan --- .../java/org/apache/doris/broker/hdfs/FileSystemManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java index beeff588bc..e10636322a 100644 --- a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java +++ b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/FileSystemManager.java @@ -662,7 +662,7 @@ public class FileSystemManager { */ public BrokerFileSystem getChdfsFileSystem(String path, Map properties) { WildcardURI pathUri = new WildcardURI(path); - String host = CHDFS_SCHEME; + String host = CHDFS_SCHEME + "://" + pathUri.getAuthority(); String authentication = properties.getOrDefault(CommonConfigurationKeysPublic.HADOOP_SECURITY_AUTHENTICATION, AUTHENTICATION_SIMPLE); if (Strings.isNullOrEmpty(authentication) || (!authentication.equals(AUTHENTICATION_SIMPLE)